Class RSocketConnectedEvent

java.lang.Object
java.util.EventObject
org.springframework.context.ApplicationEvent
org.springframework.integration.events.IntegrationEvent
org.springframework.integration.rsocket.RSocketConnectedEvent
All Implemented Interfaces:
Serializable

public class RSocketConnectedEvent extends org.springframework.integration.events.IntegrationEvent
An IntegrationEvent to indicate that RSocket from the client is connected to the server.

This event can be used for mapping RSocketRequester to the client by the headers meta-data or connect payload data.

Since:
5.2
See Also:
  • Field Summary

    Fields inherited from class org.springframework.integration.events.IntegrationEvent

    cause

    Fields inherited from class java.util.EventObject

    source
  • Constructor Summary

    Constructors
    Constructor
    Description
    RSocketConnectedEvent(Object source, Map<String,Object> headers, org.springframework.core.io.buffer.DataBuffer data, org.springframework.messaging.rsocket.RSocketRequester requester)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.core.io.buffer.DataBuffer
     
     
    org.springframework.messaging.rsocket.RSocketRequester
     
     

    Methods inherited from class org.springframework.integration.events.IntegrationEvent

    getCause, getSourceAsType

    Methods inherited from class org.springframework.context.ApplicationEvent

    getTimestamp

    Methods inherited from class java.util.EventObject

    getSource

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
  • Constructor Details

    • RSocketConnectedEvent

      public RSocketConnectedEvent(Object source, Map<String,Object> headers, org.springframework.core.io.buffer.DataBuffer data, org.springframework.messaging.rsocket.RSocketRequester requester)
  • Method Details

    • getHeaders

      public Map<String,Object> getHeaders()
    • getData

      public org.springframework.core.io.buffer.DataBuffer getData()
    • getRequester

      public org.springframework.messaging.rsocket.RSocketRequester getRequester()
    • toString

      public String toString()
      Overrides:
      toString in class org.springframework.integration.events.IntegrationEvent