Class PubSubMessage

java.lang.Object

org.chenile.pubsub.interceptor.PubSubMessage

public class PubSubMessage
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private PubSubDirection	direction
private Map<String,Object>	headers
private Map<String,Object>	metadata
private String	payload
private String	provider
private String	topic

Constructor Summary

Constructors

Constructor	Description
PubSubMessage()
PubSubMessage(String topic, String payload, Map<String,Object> headers, PubSubDirection direction, String provider, Map<String,Object> metadata)

Method Summary

Modifier and Type	Method	Description
PubSubDirection	getDirection()
Map<String,Object>	getHeaders()
Map<String,Object>	getMetadata()
String	getPayload()
String	getProvider()
String	getTopic()
void	setDirection(PubSubDirection direction)
void	setHeaders(Map<String,Object> headers)
void	setMetadata(Map<String,Object> metadata)
void	setPayload(String payload)
void	setProvider(String provider)
void	setTopic(String topic)

Methods inherited from class Object

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

Field Details

topic

private String topic

payload

private String payload

headers

private Map<String,Object> headers

direction

private PubSubDirection direction

provider

private String provider

metadata

private Map<String,Object> metadata

Constructor Details

PubSubMessage

public PubSubMessage()

PubSubMessage

public PubSubMessage(String topic,
 String payload,
 Map<String,Object> headers,
 PubSubDirection direction,
 String provider,
 Map<String,Object> metadata)

Method Details

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getPayload

public String getPayload()

setPayload

public void setPayload(String payload)

getHeaders

public Map<String,Object> getHeaders()

setHeaders

public void setHeaders(Map<String,Object> headers)

getDirection

public PubSubDirection getDirection()

setDirection

public void setDirection(PubSubDirection direction)

getProvider

public String getProvider()

setProvider

public void setProvider(String provider)

getMetadata

public Map<String,Object> getMetadata()

setMetadata

public void setMetadata(Map<String,Object> metadata)