类 JmsInvokerClientInterceptor

构造器详细资料

• JmsInvokerClientInterceptor

  public JmsInvokerClientInterceptor()

方法详细资料

• setConnectionFactory

  public void setConnectionFactory​(@Nullable
                                   ConnectionFactory connectionFactory)

  Set the QueueConnectionFactory to use for obtaining JMS QueueConnections.

• getConnectionFactory

  @Nullable
  protected ConnectionFactory getConnectionFactory()

  Return the QueueConnectionFactory to use for obtaining JMS QueueConnections.

• setQueue

  public void setQueue​(Queue queue)

  Set the target Queue to send invoker requests to.

• setQueueName

  public void setQueueName​(String queueName)

  Set the name of target queue to send invoker requests to.

  The specified name will be dynamically resolved via the DestinationResolver.

• setDestinationResolver

  public void setDestinationResolver​(@Nullable
                                     DestinationResolver destinationResolver)

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

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

  另请参阅:

  DynamicDestinationResolver, JndiDestinationResolver

• setRemoteInvocationFactory

  public void setRemoteInvocationFactory​(@Nullable
                                         RemoteInvocationFactory remoteInvocationFactory)

  Set the RemoteInvocationFactory to use for this accessor.

  Default is a DefaultRemoteInvocationFactory.

  A custom invocation factory can add further context information to the invocation, for example user credentials.

• setMessageConverter

  public void setMessageConverter​(@Nullable
                                  MessageConverter messageConverter)

  Specify the MessageConverter to use for turning RemoteInvocation objects into request messages, as well as response messages into RemoteInvocationResult objects.

  Default is a SimpleMessageConverter, using a standard JMS ObjectMessage for each invocation / invocation result object.

  Custom implementations may generally adapt Serializable objects into special kinds of messages, or might be specifically tailored for translating RemoteInvocation(Result)s into specific kinds of messages.

• setReceiveTimeout

  public void setReceiveTimeout​(long receiveTimeout)

  Set the timeout to use for receiving the response message for a request (in milliseconds).

  The default is 0, which indicates a blocking receive without timeout.

  另请参阅:

  MessageConsumer.receive(long), MessageConsumer.receive()

• getReceiveTimeout

  protected long getReceiveTimeout()

  Return the timeout to use for receiving the response message for a request (in milliseconds).

• afterPropertiesSet

  public void afterPropertiesSet()

  从接口复制的说明: InitializingBean
  Invoked by the containing BeanFactory after it has set all bean properties and satisfied BeanFactoryAware, ApplicationContextAware etc.

  This method allows the bean instance to perform validation of its overall configuration and final initialization when all bean properties have been set.

  指定者:

  afterPropertiesSet 在接口中 InitializingBean

• invoke

  @Nullable
  public Object invoke​(MethodInvocation methodInvocation)
                throws Throwable

  从接口复制的说明: MethodInterceptor
  Implement this method to perform extra treatments before and after the invocation. Polite implementations would certainly like to invoke Joinpoint.proceed().

  指定者:

  invoke 在接口中 MethodInterceptor

  参数:

  methodInvocation - the method invocation joinpoint

  返回:

  the result of the call to Joinpoint.proceed(); might be intercepted by the interceptor

  抛出:

  Throwable - if the interceptors or the target object throws an exception

• createRemoteInvocation

  protected RemoteInvocation createRemoteInvocation​(MethodInvocation methodInvocation)

  Create a new RemoteInvocation object for the given AOP method invocation.

  The default implementation delegates to the RemoteInvocationFactory.

  Can be overridden in subclasses to provide custom RemoteInvocation subclasses, containing additional invocation parameters like user credentials. Note that it is preferable to use a custom RemoteInvocationFactory which is a reusable strategy.

  参数:

  methodInvocation - the current AOP method invocation

  返回:

  the RemoteInvocation object

  另请参阅:

  RemoteInvocationFactory.createRemoteInvocation(org.aopalliance.intercept.MethodInvocation)

• executeRequest

  protected RemoteInvocationResult executeRequest​(RemoteInvocation invocation)
                                           throws JMSException

  Execute the given remote invocation, sending an invoker request message to this accessor's target queue and waiting for a corresponding response.

  参数:

  invocation - the RemoteInvocation to execute

  返回:

  the RemoteInvocationResult object

  抛出:

  JMSException - in case of JMS failure

  另请参阅:

  doExecuteRequest(javax.jms.Session, javax.jms.Queue, javax.jms.Message)

• createConnection

  protected Connection createConnection()
                                 throws JMSException

  Create a new JMS Connection for this JMS invoker.

  抛出:

  JMSException

• createSession

  protected Session createSession​(Connection con)
                           throws JMSException

  Create a new JMS Session for this JMS invoker.

  抛出:

  JMSException

• resolveQueue

  protected Queue resolveQueue​(Session session)
                        throws JMSException

  Resolve this accessor's target queue.

  参数:

  session - the current JMS Session

  返回:

  the resolved target Queue

  抛出:

  JMSException - if resolution failed

• resolveQueueName

  protected Queue resolveQueueName​(Session session,
                                   String queueName)
                            throws JMSException

  Resolve the given queue name into a JMS Queue, via this accessor's DestinationResolver.

  参数:

  session - the current JMS Session

  queueName - the name of the queue

  返回:

  the located Queue

  抛出:

  JMSException - if resolution failed

  另请参阅:

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

• createRequestMessage

  protected Message createRequestMessage​(Session session,
                                         RemoteInvocation invocation)
                                  throws JMSException

  Create the invoker request message.

  The default implementation creates a JMS ObjectMessage for the given RemoteInvocation object.

  参数:

  session - the current JMS Session

  invocation - the remote invocation to send

  返回:

  the JMS Message to send

  抛出:

  JMSException - if the message could not be created

• doExecuteRequest

  @Nullable
  protected Message doExecuteRequest​(Session session,
                                     Queue queue,
                                     Message requestMessage)
                              throws JMSException

  Actually execute the given request, sending the invoker request message to the specified target queue and waiting for a corresponding response.

  The default implementation is based on standard JMS send/receive, using a TemporaryQueue for receiving the response.

  参数:

  session - the JMS Session to use

  queue - the resolved target Queue to send to

  requestMessage - the JMS Message to send

  返回:

  the RemoteInvocationResult object

  抛出:

  JMSException - in case of JMS failure

• extractInvocationResult

  protected RemoteInvocationResult extractInvocationResult​(Message responseMessage)
                                                    throws JMSException

  Extract the invocation result from the response message.

  The default implementation expects a JMS ObjectMessage carrying a RemoteInvocationResult object. If an invalid response message is encountered, the onInvalidResponse callback gets invoked.

  参数:

  responseMessage - the response message

  返回:

  the invocation result

  抛出:

  JMSException - is thrown if a JMS exception occurs

  另请参阅:

  onInvalidResponse(javax.jms.Message)

• onReceiveTimeout

  protected RemoteInvocationResult onReceiveTimeout​(RemoteInvocation invocation)

  Callback that is invoked by executeRequest(org.springframework.remoting.support.RemoteInvocation) when the receive timeout has expired for the specified RemoteInvocation.

  By default, an RemoteTimeoutException is thrown. Sub-classes can choose to either throw a more dedicated exception or even return a default RemoteInvocationResult as a fallback.

  参数:

  invocation - the invocation

  返回:

  a default result when the receive timeout has expired

• onInvalidResponse

  protected RemoteInvocationResult onInvalidResponse​(Message responseMessage)
                                              throws JMSException

  Callback that is invoked by extractInvocationResult(javax.jms.Message) when it encounters an invalid response message.

  The default implementation throws a MessageFormatException.

  参数:

  responseMessage - the invalid response message

  返回:

  an alternative invocation result that should be returned to the caller (if desired)

  抛出:

  JMSException - if the invalid response should lead to an infrastructure exception propagated to the caller

  另请参阅:

  extractInvocationResult(javax.jms.Message)

• recreateRemoteInvocationResult

  @Nullable
  protected Object recreateRemoteInvocationResult​(RemoteInvocationResult result)
                                           throws Throwable

  Recreate the invocation result contained in the given RemoteInvocationResult object.

  The default implementation calls the default recreate() method.

  Can be overridden in subclasses to provide custom recreation, potentially processing the returned result object.

  参数:

  result - the RemoteInvocationResult to recreate

  返回:

  a return value if the invocation result is a successful return

  抛出:

  Throwable - if the invocation result is an exception

  另请参阅:

  RemoteInvocationResult.recreate()

• convertJmsInvokerAccessException

  protected RemoteAccessException convertJmsInvokerAccessException​(JMSException ex)

  Convert the given JMS invoker access exception to an appropriate Spring RemoteAccessException.

  参数:

  ex - the exception to convert

  返回:

  the RemoteAccessException to throw