public class RequestResponseJms11Sender extends Jms11Sender
AbstractJmsSender.MessageType
Constructor and Description |
---|
RequestResponseJms11Sender() |
Modifier and Type | Method and Description |
---|---|
void |
doClose() |
void |
doInit(Properties messageAttributes) |
Serializable |
doSend(Message message,
MeasurementUnit measurementUnit)
Actually performs the send operation.
|
int |
getReceiveAttempts()
Gets the maximum number of attempts to read the response message.
|
long |
getReceivingTimeout()
Gets the number of milliseconds to wait for the response message.
|
String |
getResponseConnectionFactory()
Gets the connection factory used for the response reception.
|
String |
getResponseJndiContextFactory()
Gets the JNDI context factory used for the response reception.
|
String |
getResponseJndiSecurityCredentials()
Gets the JNDI security credentials used for the response reception.
|
String |
getResponseJndiSecurityPrincipal()
Gets the JNDI security principal used for the response reception.
|
String |
getResponseJndiUrl()
Gets the JNDI URL used for the response reception.
|
String |
getResponsePassword()
Gets the JMS password used for response reception.
|
String |
getResponseTarget()
Gets the destination where the response message is being read from.
|
String |
getResponseUsername()
Gets the JMS username used for response reception.
|
boolean |
isAutoAck()
Is JMS message delivery automatically acknowledged?
|
boolean |
isUseCorrelationId()
Gets the configuration of using the correlation ID.
|
void |
preSend(Message message,
Properties messageAttributes)
Performs any action that needs to be done to send the message but is not directly related to the sending operation and thus not measured.
|
RequestResponseJms11Sender |
setAutoAck(boolean autoAck)
Enables/disables the automatic acknowledgement of JMS message delivery.
|
RequestResponseJms11Sender |
setReceiveAttempts(int receiveAttempts)
Sets the maximum number of attempts to read the response message.
|
RequestResponseJms11Sender |
setReceivingTimeout(long receivingTimeout)
Sets the number of milliseconds to wait for the response message.
|
RequestResponseJms11Sender |
setResponseConnectionFactory(String responseConnectionFactory)
Sets the connection factory used for the response reception.
|
RequestResponseJms11Sender |
setResponseJndiContextFactory(String responseJndiContextFactory)
Sets the JNDI context factory used for the response reception.
|
RequestResponseJms11Sender |
setResponseJndiSecurityCredentials(String responseJndiSecurityCredentials)
Sets the value of the JNDI security credentials for the response reception.
|
RequestResponseJms11Sender |
setResponseJndiSecurityPrincipal(String responseJndiSecurityPrincipal)
Sets the JNDI security principal used for the response reception.
|
RequestResponseJms11Sender |
setResponseJndiUrl(String responseJndiUrl)
Sets the JNDI URL used for the response reception.
|
RequestResponseJms11Sender |
setResponsePassword(String responsePassword)
Sets the JMS password used for response reception.
|
RequestResponseJms11Sender |
setResponseTarget(String responseTarget)
Sets the name of the destination where the response messages should be read from.
|
RequestResponseJms11Sender |
setResponseUsername(String responseUsername)
Sets the JMS username used for response reception.
|
RequestResponseJms11Sender |
setUseCorrelationId(boolean useCorrelationId)
Sets the configuration of using the correlation ID in response retrieval.
|
getConnectionFactory, getJndiContextFactory, getJndiSecurityCredentials, getJndiSecurityPrincipal, getJndiUrl, getMessageType, getPassword, getReplyTo, getUsername, isPersistent, isSafePropertyNames, isTransacted, setConnectionFactory, setJndiContextFactory, setJndiSecurityCredentials, setJndiSecurityPrincipal, setJndiUrl, setMessageType, setPassword, setPersistent, setReplyTo, setSafePropertyNames, setTransacted, setUsername
close, getTarget, getTarget, init, isKeepConnection, postSend, safeGetTarget, send, setKeepConnection, setTarget
public void doInit(Properties messageAttributes) throws PerfCakeException
doInit
in class Jms11Sender
PerfCakeException
public void doClose() throws PerfCakeException
doClose
in class Jms11Sender
PerfCakeException
public void preSend(Message message, Properties messageAttributes) throws Exception
MessageSender
preSend
in interface MessageSender
preSend
in class Jms11Sender
message
- Message to be sent.messageAttributes
- Attributes that can be used to replace placeholders in message and or target.Exception
- In case anything fails during the preparation.public Serializable doSend(Message message, MeasurementUnit measurementUnit) throws Exception
AbstractSender
doSend
in class Jms11Sender
message
- Message to be sent.measurementUnit
- Measurement unit carrying the current stop-watch.Exception
- When the sending operation failed.MessageSender.send(org.perfcake.message.Message, org.perfcake.reporting.MeasurementUnit)
public RequestResponseJms11Sender setUseCorrelationId(boolean useCorrelationId)
useCorrelationId
- When true, only the messages that are response to the original message can be read from the response destination. Otherwise, any response message can be read.public boolean isUseCorrelationId()
public long getReceivingTimeout()
public RequestResponseJms11Sender setReceivingTimeout(long receivingTimeout)
receivingTimeout
- Number of milliseconds to wait for the response message.public int getReceiveAttempts()
public RequestResponseJms11Sender setReceiveAttempts(int receiveAttempts)
receiveAttempts
- The maximum number of attempts to read the response message.public String getResponseTarget()
public RequestResponseJms11Sender setResponseTarget(String responseTarget)
responseTarget
- The name of the response destination.public boolean isAutoAck()
public RequestResponseJms11Sender setAutoAck(boolean autoAck)
autoAck
- true
to enable the automatic acknowledgement.public String getResponseConnectionFactory()
public RequestResponseJms11Sender setResponseConnectionFactory(String responseConnectionFactory)
responseConnectionFactory
- The connection factory used for the response reception.public String getResponseJndiContextFactory()
public RequestResponseJms11Sender setResponseJndiContextFactory(String responseJndiContextFactory)
responseJndiContextFactory
- The JNDI context factory used for the response reception.public String getResponseJndiUrl()
public RequestResponseJms11Sender setResponseJndiUrl(String responseJndiUrl)
responseJndiUrl
- The JNDI URL used for the response reception.public String getResponseJndiSecurityPrincipal()
public RequestResponseJms11Sender setResponseJndiSecurityPrincipal(String responseJndiSecurityPrincipal)
responseJndiSecurityPrincipal
- The security principal used for the response reception.public String getResponseJndiSecurityCredentials()
public RequestResponseJms11Sender setResponseJndiSecurityCredentials(String responseJndiSecurityCredentials)
responseJndiSecurityCredentials
- The JNDI security credentials to be used for the response reception.public String getResponseUsername()
public RequestResponseJms11Sender setResponseUsername(String responseUsername)
responseUsername
- The JMS username used for response reception.public String getResponsePassword()
public RequestResponseJms11Sender setResponsePassword(String responsePassword)
responsePassword
- The JMS username used for response reception.Copyright © 2010–2017 PerfCake Community. All rights reserved.