java.lang.Object
- org.springframework.messaging.simp.stomp.DefaultStompSession

所有已实现的接口:
ConnectionHandlingStompSession, StompSession, TcpConnectionHandler<byte[]>
```
public class DefaultStompSession
extends Object
implements ConnectionHandlingStompSession
```
Default implementation of ConnectionHandlingStompSession.
从以下版本开始:
4.2
作者:
Rossen Stoyanchev

嵌套类概要
- 从接口继承的嵌套类/接口 org.springframework.messaging.simp.stomp.StompSession
  StompSession.Receiptable, StompSession.Subscription

字段概要
字段
修饰符和类型字段说明
static byte[] EMPTY_PAYLOAD
An empty payload.

构造器概要
构造器
构造器说明
DefaultStompSession(StompSessionHandler sessionHandler, StompHeaders connectHeaders)
Create a new session.

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`StompSession.Receiptable`	`acknowledge(String messageId, boolean consumed)`	Send an acknowledgement whether a message was consumed or not resulting in an ACK or NACK frame respectively.
`StompSession.Receiptable`	`acknowledge(StompHeaders headers, boolean consumed)`	An overloaded version of `StompSession.acknowledge(String, boolean)` with full `StompHeaders` instead of just a `messageId`.
`void`	`afterConnected(TcpConnection<byte[]> connection)`	Invoked after a connection is successfully established.
`void`	`afterConnectFailure(Throwable ex)`	Invoked on failure to connect.
`void`	`afterConnectionClosed()`	Invoked after the connection is closed.
`void`	`disconnect()`	Disconnect the session by sending a DISCONNECT frame.
`void`	`disconnect(StompHeaders headers)`	Variant of `StompSession.disconnect()` with headers.
`MessageConverter`	`getMessageConverter()`	Return the configured `MessageConverter`.
`long`	`getReceiptTimeLimit()`	Return the configured time limit before a receipt expires.
`ListenableFuture<StompSession>`	`getSessionFuture()`	Return a future that will complete when the session is ready for use.
`StompSessionHandler`	`getSessionHandler()`	Return the configured session handler.
`String`	`getSessionId()`	Return the id for the session.
`TaskScheduler`	`getTaskScheduler()`	Return the configured TaskScheduler to use for receipt tracking.
`void`	`handleFailure(Throwable ex)`	Handle a failure on the connection.
`void`	`handleMessage(Message<byte[]> message)`	Handle a message received from the remote host.
`boolean`	`isAutoReceiptEnabled()`	Whether receipt headers should be automatically added.
`boolean`	`isConnected()`	Whether the session is connected.
`StompSession.Receiptable`	`send(String destination, Object payload)`	Send a message to the specified destination, converting the payload to a `byte[]` with the help of a `MessageConverter`.
`StompSession.Receiptable`	`send(StompHeaders headers, Object payload)`	An overloaded version of `StompSession.send(String, Object)` with full `StompHeaders` instead of just a destination.
`void`	`setAutoReceipt(boolean autoReceiptEnabled)`	When enabled, a receipt header is automatically added to future `send` and `subscribe` operations on this session, which causes the server to return a RECEIPT.
`void`	`setMessageConverter(MessageConverter messageConverter)`	Set the `MessageConverter` to use to convert the payload of incoming and outgoing messages to and from `byte[]` based on object type, or expected object type, and the "content-type" header.
`void`	`setReceiptTimeLimit(long receiptTimeLimit)`	Configure the time in milliseconds before a receipt expires.
`void`	`setTaskScheduler(TaskScheduler taskScheduler)`	Configure the TaskScheduler to use for receipt tracking.
`StompSession.Subscription`	`subscribe(String destination, StompFrameHandler handler)`	Subscribe to the given destination by sending a SUBSCRIBE frame and handle received messages with the specified `StompFrameHandler`.
`StompSession.Subscription`	`subscribe(StompHeaders headers, StompFrameHandler handler)`	An overloaded version of `StompSession.subscribe(String, StompFrameHandler)` with full `StompHeaders` instead of just a destination.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - EMPTY_PAYLOAD
```
public static final byte[] EMPTY_PAYLOAD
```
    An empty payload.
- 构造器详细资料
  - DefaultStompSession
```
public DefaultStompSession(StompSessionHandler sessionHandler,
                           StompHeaders connectHeaders)
```
    Create a new session.
    参数:
    sessionHandler - the application handler for the session
    connectHeaders - headers for the STOMP CONNECT frame
- 方法详细资料
  - getSessionId
```
public String getSessionId()
```
    从接口复制的说明: StompSession
    Return the id for the session.
    指定者:
    getSessionId 在接口中 StompSession
  - getSessionHandler
```
public StompSessionHandler getSessionHandler()
```
    Return the configured session handler.
  - getSessionFuture
```
public ListenableFuture<StompSession> getSessionFuture()
```
    从接口复制的说明: ConnectionHandlingStompSession
    Return a future that will complete when the session is ready for use.
    指定者:
    getSessionFuture 在接口中 ConnectionHandlingStompSession
  - setMessageConverter
```
public void setMessageConverter(MessageConverter messageConverter)
```
    Set the MessageConverter to use to convert the payload of incoming and outgoing messages to and from byte[] based on object type, or expected object type, and the "content-type" header.
    By default, SimpleMessageConverter is configured.
    参数:
    messageConverter - the message converter to use
  - getMessageConverter
```
public MessageConverter getMessageConverter()
```
    Return the configured MessageConverter.
  - setTaskScheduler
```
public void setTaskScheduler(@Nullable
                             TaskScheduler taskScheduler)
```
    Configure the TaskScheduler to use for receipt tracking.
  - getTaskScheduler
```
@Nullable
public TaskScheduler getTaskScheduler()
```
    Return the configured TaskScheduler to use for receipt tracking.
  - setReceiptTimeLimit
```
public void setReceiptTimeLimit(long receiptTimeLimit)
```
    Configure the time in milliseconds before a receipt expires.
    By default set to 15,000 (15 seconds).
  - getReceiptTimeLimit
```
public long getReceiptTimeLimit()
```
    Return the configured time limit before a receipt expires.
  - setAutoReceipt
```
public void setAutoReceipt(boolean autoReceiptEnabled)
```
    从接口复制的说明: StompSession
    When enabled, a receipt header is automatically added to future send and subscribe operations on this session, which causes the server to return a RECEIPT. An application can then use the Receiptable returned from the operation to track the receipt.
    A receipt header can also be added manually through the overloaded methods that accept StompHeaders.
    指定者:
    setAutoReceipt 在接口中 StompSession
  - isAutoReceiptEnabled
```
public boolean isAutoReceiptEnabled()
```
    Whether receipt headers should be automatically added.
  - isConnected
```
public boolean isConnected()
```
    从接口复制的说明: StompSession
    Whether the session is connected.
    指定者:
    isConnected 在接口中 StompSession
  - send
```
public StompSession.Receiptable send(String destination,
                                     Object payload)
```
    从接口复制的说明: StompSession
    Send a message to the specified destination, converting the payload to a byte[] with the help of a MessageConverter.
    指定者:
    send 在接口中 StompSession
    参数:
    destination - the destination to send a message to
    payload - the message payload
    返回:
    a Receiptable for tracking receipts
  - send
```
public StompSession.Receiptable send(StompHeaders headers,
                                     Object payload)
```
    从接口复制的说明: StompSession
    An overloaded version of StompSession.send(String, Object) with full StompHeaders instead of just a destination. The headers must contain a destination and may also have other headers such as "content-type" or custom headers for the broker to propagate to subscribers, or broker-specific, non-standard headers.
    指定者:
    send 在接口中 StompSession
    参数:
    headers - the message headers
    payload - the message payload
    返回:
    a Receiptable for tracking receipts
  - subscribe
```
public StompSession.Subscription subscribe(String destination,
                                           StompFrameHandler handler)
```
    从接口复制的说明: StompSession
    Subscribe to the given destination by sending a SUBSCRIBE frame and handle received messages with the specified StompFrameHandler.
    指定者:
    subscribe 在接口中 StompSession
    参数:
    destination - the destination to subscribe to
    handler - the handler for received messages
    返回:
    a handle to use to unsubscribe and/or track receipts
  - subscribe
```
public StompSession.Subscription subscribe(StompHeaders headers,
                                           StompFrameHandler handler)
```
    从接口复制的说明: StompSession
    An overloaded version of StompSession.subscribe(String, StompFrameHandler) with full StompHeaders instead of just a destination.
    指定者:
    subscribe 在接口中 StompSession
    参数:
    headers - the headers for the subscribe message frame
    handler - the handler for received messages
    返回:
    a handle to use to unsubscribe and/or track receipts
  - acknowledge
```
public StompSession.Receiptable acknowledge(String messageId,
                                            boolean consumed)
```
    从接口复制的说明: StompSession
    Send an acknowledgement whether a message was consumed or not resulting in an ACK or NACK frame respectively.
    Note: to use this when subscribing you must set the ack header to "client" or "client-individual" in order ot use this.
    指定者:
    acknowledge 在接口中 StompSession
    参数:
    messageId - the id of the message
    consumed - whether the message was consumed or not
    返回:
    a Receiptable for tracking receipts
  - acknowledge
```
public StompSession.Receiptable acknowledge(StompHeaders headers,
                                            boolean consumed)
```
    从接口复制的说明: StompSession
    An overloaded version of StompSession.acknowledge(String, boolean) with full StompHeaders instead of just a messageId.
    指定者:
    acknowledge 在接口中 StompSession
    参数:
    headers - the headers for the ACK or NACK message frame
    consumed - whether the message was consumed or not
    返回:
    a Receiptable for tracking receipts
  - disconnect
```
public void disconnect()
```
    从接口复制的说明: StompSession
    Disconnect the session by sending a DISCONNECT frame.
    指定者:
    disconnect 在接口中 StompSession
  - disconnect
```
public void disconnect(@Nullable
                       StompHeaders headers)
```
    从接口复制的说明: StompSession
    Variant of StompSession.disconnect() with headers.
    指定者:
    disconnect 在接口中 StompSession
    参数:
    headers - the headers for the disconnect message frame
  - afterConnected
```
public void afterConnected(TcpConnection<byte[]> connection)
```
    从接口复制的说明: TcpConnectionHandler
    Invoked after a connection is successfully established.
    指定者:
    afterConnected 在接口中 TcpConnectionHandler<byte[]>
    参数:
    connection - the connection
  - afterConnectFailure
```
public void afterConnectFailure(Throwable ex)
```
    从接口复制的说明: TcpConnectionHandler
    Invoked on failure to connect.
    指定者:
    afterConnectFailure 在接口中 TcpConnectionHandler<byte[]>
    参数:
    ex - the exception
  - handleMessage
```
public void handleMessage(Message<byte[]> message)
```
    从接口复制的说明: TcpConnectionHandler
    Handle a message received from the remote host.
    指定者:
    handleMessage 在接口中 TcpConnectionHandler<byte[]>
    参数:
    message - the message
  - handleFailure
```
public void handleFailure(Throwable ex)
```
    从接口复制的说明: TcpConnectionHandler
    Handle a failure on the connection.
    指定者:
    handleFailure 在接口中 TcpConnectionHandler<byte[]>
    参数:
    ex - the exception
  - afterConnectionClosed
```
public void afterConnectionClosed()
```
    从接口复制的说明: TcpConnectionHandler
    Invoked after the connection is closed.
    指定者:
    afterConnectionClosed 在接口中 TcpConnectionHandler<byte[]>

类 DefaultStompSession

嵌套类概要

从接口继承的嵌套类/接口 org.springframework.messaging.simp.stomp.StompSession

字段概要

构造器概要

方法概要

从类继承的方法 java.lang.Object

字段详细资料

EMPTY_PAYLOAD

构造器详细资料

DefaultStompSession

方法详细资料

getSessionId

getSessionHandler

getSessionFuture

setMessageConverter

getMessageConverter

setTaskScheduler

getTaskScheduler

setReceiptTimeLimit

getReceiptTimeLimit

setAutoReceipt

isAutoReceiptEnabled

isConnected

send

send

subscribe

subscribe

acknowledge

acknowledge

disconnect

disconnect

afterConnected

afterConnectFailure

handleMessage

handleFailure

afterConnectionClosed