io.eventuate.tram.messaging.producer.common

Class MessageProducerImpl

java.lang.Object

io.eventuate.tram.messaging.producer.common.MessageProducerImpl

All Implemented Interfaces:

MessageProducer

public final class MessageProducerImpl
extends java.lang.Object
implements MessageProducer

Constructor Summary

Constructors

Constructor and Description
MessageProducerImpl(MessageInterceptor[] messageInterceptors, ChannelMapping channelMapping, MessageProducerImplementation implementation)

Method Summary

Modifier and Type	Method and Description
protected void	prepareMessageHeaders(java.lang.String destination, Message message)
protected void	send(Message message)
void	send(java.lang.String destination, Message message) Send a message

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageProducerImpl

public MessageProducerImpl(MessageInterceptor[] messageInterceptors,
                           ChannelMapping channelMapping,
                           MessageProducerImplementation implementation)

Method Detail

send

public void send(java.lang.String destination,
                 Message message)

Description copied from interface: MessageProducer

Send a message

Specified by:

send in interface MessageProducer

Parameters:

destination - the destination channel

message - the message to doSend

See Also:

Message

prepareMessageHeaders

protected void prepareMessageHeaders(java.lang.String destination,
                                     Message message)

send

protected void send(Message message)