Package io.bitbucket.avalanchelaboratory.async.config

Class GeneralRabbitConfig

java.lang.Object

io.bitbucket.avalanchelaboratory.async.config.GeneralRabbitConfig

@Configuration
public class GeneralRabbitConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXCHANGE
static final String	PARKING_LOT
static final String	QUE_NAME

Constructor Summary

Constructors

Constructor	Description
GeneralRabbitConfig()

Method Summary

Modifier and Type	Method	Description
org.springframework.amqp.core.Binding	AsyncMessageBinding(org.springframework.amqp.core.DirectExchange exchange, org.springframework.amqp.core.Queue asyncMessageQueue)
org.springframework.amqp.core.DirectExchange	AsyncMessageExchange()
org.springframework.amqp.core.Queue	AsyncMessageQueue()
org.springframework.amqp.support.converter.Jackson2JsonMessageConverter	converter()
org.springframework.amqp.core.Queue	ParkingLotQueue()

Methods inherited from class java.lang.Object

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

Field Details

PARKING_LOT

public static final String PARKING_LOT

See Also:

• Constant Field Values

EXCHANGE

public static final String EXCHANGE

See Also:

• Constant Field Values

QUE_NAME

public static final String QUE_NAME

See Also:

• Constant Field Values

Constructor Details

GeneralRabbitConfig

public GeneralRabbitConfig()

Method Details

AsyncMessageExchange

@Bean
public org.springframework.amqp.core.DirectExchange AsyncMessageExchange()

ParkingLotQueue

@Bean
public org.springframework.amqp.core.Queue ParkingLotQueue()

AsyncMessageQueue

@Bean
public org.springframework.amqp.core.Queue AsyncMessageQueue()

AsyncMessageBinding

@Bean
public org.springframework.amqp.core.Binding AsyncMessageBinding(@Qualifier("AsyncMessageExchange")
 org.springframework.amqp.core.DirectExchange exchange,
 @Qualifier("AsyncMessageQueue")
 org.springframework.amqp.core.Queue asyncMessageQueue)

converter

@Bean
public org.springframework.amqp.support.converter.Jackson2JsonMessageConverter converter()