Class JmsDestinationAccessor

Field Detail

• RECEIVE_TIMEOUT_NO_WAIT

  public static final long RECEIVE_TIMEOUT_NO_WAIT

  Timeout value indicating that a receive operation should check if a message is immediately available without blocking.

  Since:

  4.3

  See Also:

  Constant Field Values

• RECEIVE_TIMEOUT_INDEFINITE_WAIT

  public static final long RECEIVE_TIMEOUT_INDEFINITE_WAIT

  Timeout value indicating a blocking receive without timeout.

  Since:

  4.3

  See Also:

  Constant Field Values

Constructor Detail

• JmsDestinationAccessor

  public JmsDestinationAccessor()

Method Detail

• setDestinationResolver

  public void setDestinationResolver​(DestinationResolver destinationResolver)

  Set the DestinationResolver that is to be used to resolve Destination references for this accessor.

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

  See Also:

  DynamicDestinationResolver, JndiDestinationResolver

• getDestinationResolver

  public DestinationResolver getDestinationResolver()

  Return the DestinationResolver for this accessor (never null).

• setPubSubDomain

  public void setPubSubDomain​(boolean pubSubDomain)

  Configure the destination accessor with knowledge of the JMS domain used. Default is Point-to-Point (Queues).

  This setting primarily indicates what type of destination to resolve if dynamic destinations are enabled.

  Parameters:

  pubSubDomain - "true" for the Publish/Subscribe domain (Topics), "false" for the Point-to-Point domain (Queues)

  See Also:

  setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)

• isPubSubDomain

  public boolean isPubSubDomain()

  Return whether the Publish/Subscribe domain (Topics) is used. Otherwise, the Point-to-Point domain (Queues) is used.

• resolveDestinationName

  protected Destination resolveDestinationName​(Session session,
                                               String destinationName)
                                        throws JMSException

  Resolve the given destination name into a JMS Destination, via this accessor's DestinationResolver.

  Parameters:

  session - the current JMS Session

  destinationName - the name of the destination

  Returns:

  the located Destination

  Throws:

  JMSException - if resolution failed

  See Also:

  setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)

• receiveFromConsumer

  @Nullable
  protected Message receiveFromConsumer​(MessageConsumer consumer,
                                        long timeout)
                                 throws JMSException

  Actually receive a message from the given consumer.

  Parameters:

  consumer - the JMS MessageConsumer to receive with

  timeout - the receive timeout (a negative value indicates a no-wait receive; 0 indicates an indefinite wait attempt)

  Returns:

  the JMS Message received, or null if none

  Throws:

  JMSException - if thrown by JMS API methods

  Since:

  4.3

  See Also:

  RECEIVE_TIMEOUT_NO_WAIT, RECEIVE_TIMEOUT_INDEFINITE_WAIT