类 AbstractAdaptableMessageListener

字段详细资料

• logger

  protected final Log logger

  Logger available to subclasses.

构造器详细资料

• AbstractAdaptableMessageListener

  public AbstractAdaptableMessageListener()

方法详细资料

• setDefaultResponseDestination

  public void setDefaultResponseDestination​(Destination destination)

  Set the default destination to send response messages to. This will be applied in case of a request message that does not carry a "JMSReplyTo" field.

  Response destinations are only relevant for listener methods that return result objects, which will be wrapped in a response message and sent to a response destination.

  Alternatively, specify a "defaultResponseQueueName" or "defaultResponseTopicName", to be dynamically resolved via the DestinationResolver.

  另请参阅:

  setDefaultResponseQueueName(String), setDefaultResponseTopicName(String), getResponseDestination(javax.jms.Message, javax.jms.Message, javax.jms.Session, java.lang.Object)

• setDefaultResponseQueueName

  public void setDefaultResponseQueueName​(String destinationName)

  Set the name of the default response queue to send response messages to. This will be applied in case of a request message that does not carry a "JMSReplyTo" field.

  Alternatively, specify a JMS Destination object as "defaultResponseDestination".

  另请参阅:

  setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver), setDefaultResponseDestination(javax.jms.Destination)

• setDefaultResponseTopicName

  public void setDefaultResponseTopicName​(String destinationName)

  Set the name of the default response topic to send response messages to. This will be applied in case of a request message that does not carry a "JMSReplyTo" field.

  Alternatively, specify a JMS Destination object as "defaultResponseDestination".

  另请参阅:

  setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver), setDefaultResponseDestination(javax.jms.Destination)

• setDestinationResolver

  public void setDestinationResolver​(DestinationResolver destinationResolver)

  Set the DestinationResolver that should be used to resolve response destination names for this adapter.

  The default resolver is a DynamicDestinationResolver. Specify a JndiDestinationResolver for resolving destination names as JNDI locations.

  另请参阅:

  DynamicDestinationResolver, JndiDestinationResolver

• getDestinationResolver

  protected DestinationResolver getDestinationResolver()

  Return the DestinationResolver for this adapter.

• setMessageConverter

  public void setMessageConverter​(@Nullable
                                  MessageConverter messageConverter)

  Set the converter that will convert incoming JMS messages to listener method arguments, and objects returned from listener methods back to JMS messages.

  The default converter is a SimpleMessageConverter, which is able to handle BytesMessages, TextMessages and ObjectMessages.

• getMessageConverter

  @Nullable
  protected MessageConverter getMessageConverter()

  Return the converter that will convert incoming JMS messages to listener method arguments, and objects returned from listener methods back to JMS messages.

• setHeaderMapper

  public void setHeaderMapper​(JmsHeaderMapper headerMapper)

  Set the JmsHeaderMapper implementation to use to map the standard JMS headers. By default, a SimpleJmsHeaderMapper is used.

  另请参阅:

  SimpleJmsHeaderMapper

• getMessagingMessageConverter

  protected final MessagingMessageConverter getMessagingMessageConverter()

  Return the MessagingMessageConverter for this listener, being able to convert Message.

• setResponseQosSettings

  public void setResponseQosSettings​(@Nullable
                                     QosSettings responseQosSettings)

  Set the QosSettings to use when sending a response. Can be set to null to indicate that the broker's defaults should be used.

  参数:

  responseQosSettings - the QoS settings to use when sending a response or null to use the default values.

  从以下版本开始:

  5.0

• getResponseQosSettings

  @Nullable
  protected QosSettings getResponseQosSettings()

  Return the QosSettings to use when sending a response, or null if the defaults should be used.

  从以下版本开始:

  5.0

• onMessage

  public void onMessage​(Message message)

  Standard JMS MessageListener entry point.

  Delegates the message to the target listener method, with appropriate conversion of the message argument. In case of an exception, the handleListenerException(Throwable) method will be invoked.

  Note: Does not support sending response messages based on result objects returned from listener methods. Use the SessionAwareMessageListener entry point (typically through a Spring message listener container) for handling result objects as well.

  指定者:

  onMessage 在接口中 MessageListener

  参数:

  message - the incoming JMS message

  另请参阅:

  handleListenerException(java.lang.Throwable), onMessage(javax.jms.Message, javax.jms.Session)

• onMessage

  public abstract void onMessage​(Message message,
                                 @Nullable
                                 Session session)
                          throws JMSException

  从接口复制的说明: SessionAwareMessageListener
  Callback for processing a received JMS message.

  Implementors are supposed to process the given Message, typically sending reply messages through the given Session.

  指定者:

  onMessage 在接口中 SessionAwareMessageListener<Message>

  参数:

  message - the received JMS message (never null)

  session - the underlying JMS Session (never null)

  抛出:

  JMSException - if thrown by JMS methods

• handleListenerException

  protected void handleListenerException​(Throwable ex)

  Handle the given exception that arose during listener execution. The default implementation logs the exception at error level.

  This method only applies when used as standard JMS MessageListener. In case of the Spring SessionAwareMessageListener mechanism, exceptions get handled by the caller instead.

  参数:

  ex - the exception to handle

  另请参阅:

  onMessage(javax.jms.Message)

• extractMessage

  protected Object extractMessage​(Message message)

  Extract the message body from the given JMS message.

  参数:

  message - the JMS Message

  返回:

  the content of the message, to be passed into the listener method as an argument

  抛出:

  MessageConversionException - if the message could not be extracted

• handleResult

  protected void handleResult​(Object result,
                              Message request,
                              @Nullable
                              Session session)

  Handle the given result object returned from the listener method, sending a response message back.

  参数:

  result - the result object to handle (never null)

  request - the original request message

  session - the JMS Session to operate on (may be null)

  抛出:

  ReplyFailureException - if the response message could not be sent

  另请参阅:

  buildMessage(javax.jms.Session, java.lang.Object), postProcessResponse(javax.jms.Message, javax.jms.Message), getResponseDestination(javax.jms.Message, javax.jms.Message, javax.jms.Session, java.lang.Object), sendResponse(javax.jms.Session, javax.jms.Destination, javax.jms.Message)

• buildMessage

  protected Message buildMessage​(Session session,
                                 Object result)
                          throws JMSException

  Build a JMS message to be sent as response based on the given result object.

  参数:

  session - the JMS Session to operate on

  result - the content of the message, as returned from the listener method

  返回:

  the JMS Message (never null)

  抛出:

  JMSException - if thrown by JMS API methods

  另请参阅:

  setMessageConverter(org.springframework.jms.support.converter.MessageConverter)

• preProcessResponse

  protected Object preProcessResponse​(Object result)

  Pre-process the given result before it is converted to a Message.

  参数:

  result - the result of the invocation

  返回:

  the payload response to handle, either the result argument or any other object (for instance wrapping the result).

  从以下版本开始:

  4.3

• postProcessResponse

  protected void postProcessResponse​(Message request,
                                     Message response)
                              throws JMSException

  Post-process the given response message before it will be sent.

  The default implementation sets the response's correlation id to the request message's correlation id, if any; otherwise to the request message id.

  参数:

  request - the original incoming JMS message

  response - the outgoing JMS message about to be sent

  抛出:

  JMSException - if thrown by JMS API methods

  另请参阅:

  Message.setJMSCorrelationID(java.lang.String)

• getResponseDestination

  protected Destination getResponseDestination​(Message request,
                                               Message response,
                                               Session session)
                                        throws JMSException

  Determine a response destination for the given message.

  The default implementation first checks the JMS Reply-To Destination of the supplied request; if that is not null it is returned; if it is null, then the configured default response destination is returned; if this too is null, then an InvalidDestinationException is thrown.

  参数:

  request - the original incoming JMS message

  response - the outgoing JMS message about to be sent

  session - the JMS Session to operate on

  返回:

  the response destination (never null)

  抛出:

  JMSException - if thrown by JMS API methods

  InvalidDestinationException - if no Destination can be determined

  另请参阅:

  setDefaultResponseDestination(javax.jms.Destination), Message.getJMSReplyTo()

• resolveDefaultResponseDestination

  @Nullable
  protected Destination resolveDefaultResponseDestination​(Session session)
                                                   throws JMSException

  Resolve the default response destination into a JMS Destination, using this accessor's DestinationResolver in case of a destination name.

  返回:

  the located Destination

  抛出:

  JMSException - if resolution failed

  另请参阅:

  setDefaultResponseDestination(javax.jms.Destination), setDefaultResponseQueueName(java.lang.String), setDefaultResponseTopicName(java.lang.String), setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)

• sendResponse

  protected void sendResponse​(Session session,
                              Destination destination,
                              Message response)
                       throws JMSException

  Send the given response message to the given destination.

  参数:

  response - the JMS message to send

  destination - the JMS destination to send to

  session - the JMS session to operate on

  抛出:

  JMSException - if thrown by JMS API methods

  另请参阅:

  postProcessProducer(javax.jms.MessageProducer, javax.jms.Message), Session.createProducer(javax.jms.Destination), MessageProducer.send(javax.jms.Message)

• postProcessProducer

  protected void postProcessProducer​(MessageProducer producer,
                                     Message response)
                              throws JMSException

  Post-process the given message producer before using it to send the response.

  The default implementation is empty.

  参数:

  producer - the JMS message producer that will be used to send the message

  response - the outgoing JMS message about to be sent

  抛出:

  JMSException - if thrown by JMS API methods