1. 28 9月, 2013 1 次提交
  2. 27 9月, 2013 15 次提交
    • R
      Merge pull request #364 from mikesir87/ws-glassfish4-support · f3611e76
      Rossen Stoyanchev 提交于
      * mikesir87-ws-glassfish4-support:
        Added websocket upgrade support for GlassFish 4.0
      f3611e76
    • M
      Added websocket upgrade support for GlassFish 4.0 · f1e929f3
      Michael Irwin 提交于
      Commit 2397b210 changed websocket
      support to use GlassFish 4.0.1 nightlies, but broke support for 4.0. In
      GlassFish 4.0.1, the package that TyrusEndpoint is located in changed.
      This commit provides an abstract handler that does all required
      GlassFish setup, but delegates to version specific upgrade handlers to
      create the final TyrusEndpoint.
      
      GlassFish 4.0 handler uses reflection to create its endpoint to prevent
      dependency issues of depending on different versions of
      tyrus-websocket-core and tyrus-container-servlet
      f1e929f3
    • R
      Polish logging · c06ea3b4
      Rossen Stoyanchev 提交于
      c06ea3b4
    • P
      Remove unused snapshot repository definition · 6ca8346e
      Phillip Webb 提交于
      6ca8346e
    • R
      Merge multiple pull requests from wilkinsona · d5dfd1b4
      Rossen Stoyanchev 提交于
      * broker-relay:
        Polish
        Improve handling of missed heartbeats
        Upgrade to Reactor 1.0.0.M3
        Add heart-beat support to STOMP broker relay
        Remove CONNECT-related message buffer from STOMP relay
        Add StompCodec
      d5dfd1b4
    • R
      Polish · 469aaa87
      Rossen Stoyanchev 提交于
      469aaa87
    • A
      Improve handling of missed heartbeats · 6679feb7
      Andy Wilkinson 提交于
      Previously, when a broker heartbeat was mnissed, the STOMP connection
      would be left in a semi-disconnected state such that, for example, the
      read and write idle callbacks would still be active, even though
      the underlying TCP connection had been nulled out.
      
      As part of disconnecting the STOMP connection, this commit closes the
      underlying TCP connection when a heartbeat's missed which cancels the
      read and write idle callbacks. It also now copes with the underlying
      TCP connection being null when sending a heartbeat to the broker. This
      protects again a race condition between the write idle callback being
      fired, such that a heartbeat needs to be sent, and the connection
      being nulled out due to it being closed.
      6679feb7
    • A
      Upgrade to Reactor 1.0.0.M3 · bae9134a
      Andy Wilkinson 提交于
      bae9134a
    • A
      Add heart-beat support to STOMP broker relay · 496d8321
      Andy Wilkinson 提交于
      Previously, the STOMP broker relay did not support heart-beats. It sent
      0,0 in the heart-beats header for its own CONNECTED message, and set the
      heart-beats header to 0,0 when it was forwarding a CONNECTED from from a
      client to the broker.
      
      The broker relay now supports heart-beats for the system relay session.
      It will send heart-beats at the send interval that's been negotiated
      with the broker and will also expect to receive heart-beats at the
      receive interval that's been negotiated with the broker. The receive
      interval is multiplied by a factor of three to satisfy the STOMP spec's
      suggestion of lenience and ActiveMQ 5.8.0's heart-beat behaviour (see
      AMQ-4710).
      
      The broker relay also supports heart-beats between clients and the
      broker. For any given client's relay session, any heart-beats received
      from the client are forwarded on to the broker and any heart-beats
      received from the broker are sent back to the client.
      
      Internally, a heart-beat is represented as a Message with a byte array
      payload containing the single byte of new line ('\n') character and
      'empty' headers. SubscriptionMethodReturnValueHandler has been updated
      to default the message type to SimpMessageType.MESSAGE. This eases
      the distinction between a heartbeat and a message that's been created
      from a return value from application code.
      496d8321
    • A
      Remove CONNECT-related message buffer from STOMP relay · 8d2a376b
      Andy Wilkinson 提交于
      Before this change, the StompProtocolHandler always responded to
      clients with a CONNECTED frame, while the STOMP broker relay
      independantly forwarded the client CONNECT to the broker and waited
      for the CONNECTED frame back. That meant the relay had to buffer
      client messages until it received the CONNECTED response from
      the message broker.
      
      This change ensures that clients wait for a CONNECTED frame from
      the message broker. The broker relay forwards the CONNECT frame to
      the broker. The broker responds with a CONNECTED frame, which the
      relay then forwards to the client. As a result, a (well-written)
      client will not send any messages to the relay until the connection
      to the broker is fully established.
      
      The StompProtcolHandler can now be configured whether to send CONNECTED
      frame back. By default that is off. So when using the simple broker,
      the StompProtocolHandler can still respond with CONNECTED frames.
      
      The relay's handling of a connection being dropped has also been
      improved. When a connection for a client relay session is dropped
      an ERROR frame will be sent back to the client. If a connection is
      closed as part of a DISCONNECT frame being sent, no ERROR frame
      is sent back to the client. When the connection for the system relay
      session is dropped, an event is published indicating that the broker
      is unavailable. Reactor's TcpClient will then attempt to re-restablish
      the connection.
      8d2a376b
    • A
      Add StompCodec · a489c2cf
      Andy Wilkinson 提交于
      Previously, the broker relay's TCP client used Reactor's built in
      delimited codec as part of its parsing of STOMP frames. \0 was used as
      the delimiter. This worked for most STOMP frames but, crucially,
      not for frames with a body that contained \0: when such a frame was
      received it would be truncated.
      
      This commit adds a custom codec that parses STOMP frames more
      intelligently. It honours the content-length header allowing it to
      correctly parse frames with a body that contains \0. The codec largely
      delegates to two new classes: StompEncoder and StompDecoder. For
      consistency, code that previously used StompMessageConverter has been
      reworked to use these new encoder and decoder classes.
      
      Issue: SPR-10818
      a489c2cf
    • J
      Added ASPECTJ and REGEX constants to FilterType, along with a corresponding... · f705ec1a
      Juergen Hoeller 提交于
      Added ASPECTJ and REGEX constants to FilterType, along with a corresponding 'pattern' attribute on ComponentScan.Filter
      
      Issue: SPR-10593
      f705ec1a
    • J
      Silently swallow IllegalStateException on commit if the JMS transaction is... · 11d20e33
      Juergen Hoeller 提交于
      Silently swallow IllegalStateException on commit if the JMS transaction is based on a JDBC transaction
      
      This fine-tuned change restores the original Spring 3.0 behavior for Oracle AQ, and also allows for other ConnectionFactory types to comply with the "getDataSource()" pattern.
      
      Issue: SPR-10829
      11d20e33
    • J
      d3f063d0
    • R
      Enable cookie_needed by default in SockJS service · 77fa8698
      Rossen Stoyanchev 提交于
      Issue: SPR-10939
      77fa8698
  3. 26 9月, 2013 7 次提交
  4. 25 9月, 2013 9 次提交
  5. 24 9月, 2013 5 次提交
  6. 21 9月, 2013 2 次提交
  7. 14 9月, 2013 1 次提交