org.kaazing.gateway.server.messaging

Interface MessagingProvider

public interface MessagingProvider

Primary messaging interface used to acquire a Session, from which all other work is done.

Method Summary

Modifier and Type	Method and Description
void	acquireSession(Map<String,Object> attributes, MessagingSessionListener listener)
void	acquireSession(MessagingSessionListener listener)
void	acquireSession(String sessionId, Map<String,Object> attributes, MessagingSessionListener listener) Acquire a unique exclusive session with the messaging provider.
void	acquireSession(String sessionId, MessagingSessionListener listener)
void	reacquireSession(String sessionId, MessagingSessionListener listener)
void	releaseSession(MessagingSession session)
void	releaseSession(MessagingSession session, boolean reacquireable)
void	releaseSession(String sessionId)
void	releaseSession(String sessionId, boolean reacquireable)

Method Detail

acquireSession

void acquireSession(String sessionId,
                    Map<String,Object> attributes,
                    MessagingSessionListener listener)

Acquire a unique exclusive session with the messaging provider.

Sessions are exclusive, meaning they can only be associated with one listener at a time. Any subsequent attempt to acquire a session with the same id will result in the original listener being notified of a release and then the new listener being notified of an acquire.

Parameters:

sessionId - requested identifier for this session

attributes - initial session attributes

listener - callback for session events

acquireSession

void acquireSession(Map<String,Object> attributes,
                    MessagingSessionListener listener)

Parameters:

attributes -

listener -

acquireSession

void acquireSession(String sessionId,
                    MessagingSessionListener listener)

Parameters:

sessionId -

listener -

acquireSession

void acquireSession(MessagingSessionListener listener)

Parameters:

listener -

reacquireSession

void reacquireSession(String sessionId,
                      MessagingSessionListener listener)

Parameters:

sessionId -

listener -

releaseSession

void releaseSession(String sessionId,
                    boolean reacquireable)

Parameters:

sessionId -

reacquireable -

releaseSession

void releaseSession(String sessionId)

Parameters:

sessionId -

releaseSession

void releaseSession(MessagingSession session,
                    boolean reacquireable)

Parameters:

session -

reacquireable -

releaseSession

void releaseSession(MessagingSession session)

Parameters:

session -