Class RabbitOperationsOutboundEventChannelAdapter

java.lang.Object

org.flowable.eventregistry.spring.rabbit.RabbitOperationsOutboundEventChannelAdapter

All Implemented Interfaces:

OutboundEventChannelAdapter<String>

public class RabbitOperationsOutboundEventChannelAdapter
extends Object
implements OutboundEventChannelAdapter<String>

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected String	exchange
protected RabbitOperations	rabbitOperations
protected String	routingKey

Constructor Summary

Constructors

Constructor	Description
RabbitOperationsOutboundEventChannelAdapter(RabbitOperations rabbitOperations, String exchange, String routingKey)

Method Summary

Modifier and Type	Method	Description
String	getExchange()
RabbitOperations	getRabbitOperations()
String	getRoutingKey()
void	sendEvent(String rawEvent, Map<String,Object> headerMap)
void	setExchange(String exchange)
void	setRabbitOperations(RabbitOperations rabbitOperations)
void	setRoutingKey(String routingKey)

Methods inherited from class Object

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

Methods inherited from interface OutboundEventChannelAdapter

sendEvent

Field Details

rabbitOperations

protected RabbitOperations rabbitOperations

exchange

protected String exchange

routingKey

protected String routingKey

Constructor Details

RabbitOperationsOutboundEventChannelAdapter

public RabbitOperationsOutboundEventChannelAdapter(RabbitOperations rabbitOperations,
 String exchange,
 String routingKey)

Method Details

sendEvent

public void sendEvent(String rawEvent,
 Map<String,Object> headerMap)

Specified by:

sendEvent in interface OutboundEventChannelAdapter<String>

getRabbitOperations

public RabbitOperations getRabbitOperations()

setRabbitOperations

public void setRabbitOperations(RabbitOperations rabbitOperations)

getExchange

public String getExchange()

setExchange

public void setExchange(String exchange)

getRoutingKey

public String getRoutingKey()

setRoutingKey

public void setRoutingKey(String routingKey)