Package org.flowable.eventregistry.spring.rabbit

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 java.lang.Object

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

Methods inherited from interface org.flowable.eventregistry.api.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)