org.yamcs.security

Class ArtemisAuthInterceptor

java.lang.Object

org.yamcs.security.ArtemisAuthInterceptor

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.BaseInterceptor<org.apache.activemq.artemis.core.protocol.core.Packet>, org.apache.activemq.artemis.api.core.Interceptor

public class ArtemisAuthInterceptor
extends Object
implements org.apache.activemq.artemis.api.core.Interceptor

Caches the username from an incoming CreateSessionMessage against its connection, and injects the username into all subsequent Messages from the connection until a SessionCloseMessage is sent by the client. When a CreateSessionMessage or a SessionCloseMessage is received, the cache is also flushed to remove all connections which have a disconnected status.

Author:

atu

Field Summary

Fields

Modifier and Type	Field and Description
static String	USERNAME_PROPERTY

Constructor Summary

Constructors

Constructor and Description
ArtemisAuthInterceptor()

Method Summary

Modifier and Type	Method and Description
org.yamcs.security.AuthInjectionAssociation	cache(String username, org.apache.activemq.artemis.spi.core.protocol.RemotingConnection conn) Adds the user to the cache so all subsequent Messages have the username injected.
void	flush(Object connectionId) Stops username injection for the specified connection.
void	flush(String username) Stops username injection for all connections made with the specified username.
void	flushDisconnected() Stops username injection for all connections which have been destroyed.
Map<Object,org.yamcs.security.AuthInjectionAssociation>	getCache()
boolean	intercept(org.apache.activemq.artemis.core.protocol.core.Packet packet, org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

USERNAME_PROPERTY

public static final String USERNAME_PROPERTY

See Also:

Constant Field Values

Constructor Detail

ArtemisAuthInterceptor

public ArtemisAuthInterceptor()

Method Detail

intercept

public boolean intercept(org.apache.activemq.artemis.core.protocol.core.Packet packet,
                         org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection)
                  throws org.apache.activemq.artemis.api.core.ActiveMQException

Specified by:

intercept in interface org.apache.activemq.artemis.api.core.BaseInterceptor<org.apache.activemq.artemis.core.protocol.core.Packet>

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

cache

public org.yamcs.security.AuthInjectionAssociation cache(String username,
                                                         org.apache.activemq.artemis.spi.core.protocol.RemotingConnection conn)

Adds the user to the cache so all subsequent Messages have the username injected.

Parameters:

username -

conn -

Returns:

flush

public void flush(Object connectionId)

Stops username injection for the specified connection. Note a single client may make many connections.

Parameters:

connectionId -

flush

public void flush(String username)

Stops username injection for all connections made with the specified username. Note a single username may be shared across many connections.

Parameters:

username -

flushDisconnected

public void flushDisconnected()

Stops username injection for all connections which have been destroyed.

getCache

public Map<Object,org.yamcs.security.AuthInjectionAssociation> getCache()