Package ca.cdr.api.broker

Class PublicBrokerSendRequest<P>

java.lang.Object

ca.cdr.api.broker.PublicBrokerSendRequest<P>

All Implemented Interfaces:

IPublicBrokerSendRequest<P>

public class PublicBrokerSendRequest<P>
extends Object
implements IPublicBrokerSendRequest<P>

Constructor Summary

Constructors

Constructor	Description
PublicBrokerSendRequest(String theChannelName, P thePayload, Class<? extends IMessage<P>> theMessageType, Class<P> thePayloadType, Map<String,Object> theHeaders)

Method Summary

Modifier and Type	Method	Description
String	getChannelName()
Map<String,Object>	getHeaders()
Class<? extends IMessage<P>>	getMessageType()
P	getPayload()
Class<P>	getPayloadType()

Methods inherited from class java.lang.Object

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

Constructor Details

PublicBrokerSendRequest

public PublicBrokerSendRequest(String theChannelName,
 P thePayload,
 Class<? extends IMessage<P>> theMessageType,
 Class<P> thePayloadType,
 Map<String,Object> theHeaders)

Method Details

getChannelName

public String getChannelName()

Specified by:

getChannelName in interface IPublicBrokerSendRequest<P>

Returns:

the Broker topic

getPayload

public P getPayload()

Specified by:

getPayload in interface IPublicBrokerSendRequest<P>

getMessageType

public Class<? extends IMessage<P>> getMessageType()

Specified by:

getMessageType in interface IPublicBrokerSendRequest<P>

getPayloadType

public Class<P> getPayloadType()

Specified by:

getPayloadType in interface IPublicBrokerSendRequest<P>

getHeaders

public Map<String,Object> getHeaders()

Specified by:

getHeaders in interface IPublicBrokerSendRequest<P>