Package io.mats3.matssocket

Class ClusterStoreAndForward.SimpleRequestCorrelation

java.lang.Object

io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

All Implemented Interfaces:

ClusterStoreAndForward.RequestCorrelation

Enclosing interface:

ClusterStoreAndForward

public static class ClusterStoreAndForward.SimpleRequestCorrelation
extends Object
implements ClusterStoreAndForward.RequestCorrelation

Constructor Summary

Constructors

Constructor	Description
SimpleRequestCorrelation(String matsSocketSessionId, String serverMessageId, long requestTimestamp, String replyTerminatorId, String correlationString, byte[] correlationBinary)

Method Summary

Modifier and Type	Method	Description
byte[]	getCorrelationBinary()
String	getCorrelationString()
String	getMatsSocketSessionId()
String	getReplyTerminatorId()
long	getRequestTimestamp()
String	getServerMessageId()

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleRequestCorrelation

public SimpleRequestCorrelation(String matsSocketSessionId,
 String serverMessageId,
 long requestTimestamp,
 String replyTerminatorId,
 String correlationString,
 byte[] correlationBinary)

Method Details

getMatsSocketSessionId

public String getMatsSocketSessionId()

Specified by:

getMatsSocketSessionId in interface ClusterStoreAndForward.RequestCorrelation

getServerMessageId

public String getServerMessageId()

Specified by:

getServerMessageId in interface ClusterStoreAndForward.RequestCorrelation

getRequestTimestamp

public long getRequestTimestamp()

Specified by:

getRequestTimestamp in interface ClusterStoreAndForward.RequestCorrelation

getReplyTerminatorId

public String getReplyTerminatorId()

Specified by:

getReplyTerminatorId in interface ClusterStoreAndForward.RequestCorrelation

getCorrelationString

public String getCorrelationString()

Specified by:

getCorrelationString in interface ClusterStoreAndForward.RequestCorrelation

getCorrelationBinary

public byte[] getCorrelationBinary()

Specified by:

getCorrelationBinary in interface ClusterStoreAndForward.RequestCorrelation