Package energy.eddie.outbound.amqp

Class AmqpOutboundConnector

java.lang.Object

energy.eddie.outbound.amqp.AmqpOutboundConnector

@SpringBootApplication
public class AmqpOutboundConnector
extends Object

Constructor Summary

Constructors

Constructor	Description
AmqpOutboundConnector()

Method Summary

Modifier and Type	Method	Description
com.rabbitmq.client.amqp.Environment	amqpEnvironment()
com.rabbitmq.client.amqp.Connection	connection(com.rabbitmq.client.amqp.Environment environment, String uri, TopicConfiguration topicConfiguration)
MessageSerde	serde(String format)
TopicConfiguration	topicConfiguration(String eddieId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AmqpOutboundConnector

public AmqpOutboundConnector()

Method Details

topicConfiguration

@Bean
public TopicConfiguration topicConfiguration(@Value("${outbound-connector.amqp.eddie-id}")
 String eddieId)

amqpEnvironment

@Bean
public com.rabbitmq.client.amqp.Environment amqpEnvironment()

connection

@Bean
public com.rabbitmq.client.amqp.Connection connection(com.rabbitmq.client.amqp.Environment environment,
 @Value("${outbound-connector.amqp.uri}")
 String uri,
 TopicConfiguration topicConfiguration)

serde

@Bean
public MessageSerde serde(@Value("${outbound-connector.amqp.format:json}")
 String format)
                   throws SerdeInitializationException

Throws:

SerdeInitializationException