public abstract class AbstractStompSessionManager extends ObjectSE implements StompSessionManager, ApplicationEventPublisherAware, SmartLifecycle, DisposableBean, BeanNameAware
ListenableFuture 上で単一の StompSession を管理するためのベース StompSessionManager 実装。StompSession への接続は、start() 中に行われます。
stop() ライフサイクルメソッドは StompSession.disconnect() を管理します。
connect(StompSessionHandler) および disconnect(StompSessionHandler) メソッドの実装は、提供された StompSessionHandler を内部 AbstractStompSessionManager.CompositeStompSessionHandler との間で入力 / 削除します。これにより、すべての操作が提供された StompSessionHandler に委譲されます。この AbstractStompSessionManager.CompositeStompSessionHandler は、StompSession 接続に使用されます。
| 修飾子と型 | フィールドと説明 |
|---|---|
protected Log | logger |
protected StompClientSupport | stompClient |
DEFAULT_PHASE| コンストラクターと説明 |
|---|
AbstractStompSessionManager(StompClientSupport stompClient) |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | connect(StompSessionHandler handler) |
void | destroy() |
void | disconnect(StompSessionHandler handler) |
protected abstract ListenableFuture<StompSession> | doConnect(StompSessionHandler handler) |
protected StompHeaders | getConnectHeaders() |
int | getPhase() |
long | getRecoveryInterval() |
boolean | isAutoReceiptEnabled() |
boolean | isAutoStartup() |
boolean | isConnected() |
boolean | isRunning() |
void | setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void | setAutoReceipt(boolean autoReceipt) |
void | setAutoStartup(boolean autoStartup) |
void | setBeanName(StringSE name) |
void | setConnectHeaders(StompHeaders connectHeaders) |
void | setPhase(int phase) |
void | setRecoveryInterval(int recoveryInterval) 接続が失われた場合の再接続間隔をミリ秒単位で指定します。 |
void | start() |
void | stop() |
StringSE | toString() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEstopprotected final Log logger
protected final StompClientSupport stompClient
public AbstractStompSessionManager(StompClientSupport stompClient)
public void setConnectHeaders(StompHeaders connectHeaders)
public void setAutoReceipt(boolean autoReceipt)
public boolean isAutoReceiptEnabled()
StompSessionManager 内の isAutoReceiptEnabled public boolean isConnected()
StompSessionManager 内の isConnected public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
ApplicationEventPublisherAware 内の setApplicationEventPublisher public void setBeanName(StringSE name)
BeanNameAware 内の setBeanName public void setRecoveryInterval(int recoveryInterval)
recoveryInterval - 接続が失われた場合のミリ秒単位の再接続間隔。public void setAutoStartup(boolean autoStartup)
public void setPhase(int phase)
public long getRecoveryInterval()
public boolean isAutoStartup()
SmartLifecycle 内の isAutoStartup public int getPhase()
Phased 内の getPhase SmartLifecycle 内の getPhase public void destroy()
DisposableBean 内の destroy public void connect(StompSessionHandler handler)
StompSessionManager 内の connect public void disconnect(StompSessionHandler handler)
StompSessionManager 内の disconnect protected StompHeaders getConnectHeaders()
public StringSE toString()
ObjectSE の toStringSE protected abstract ListenableFuture<StompSession> doConnect(StompSessionHandler handler)