services.moleculer.transporter

Class InternalTransporter.Subscriptions

java.lang.Object

services.moleculer.transporter.InternalTransporter.Subscriptions

Enclosing class:

InternalTransporter

public static class InternalTransporter.Subscriptions
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	readLock
protected java.util.HashMap<java.lang.String,InternalTransporter.SubscriptionSet>	sets
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	writeLock

Constructor Summary

Constructors

Constructor and Description
Subscriptions()

Method Summary

Modifier and Type	Method and Description
protected void	deregister(java.lang.String channel, InternalTransporter transporter, boolean shared)
protected InternalTransporter.SubscriptionSet	getSubscriptionSet(java.lang.String channel)
protected void	register(java.lang.String channel, InternalTransporter transporter)
protected void	send(java.lang.String channel, byte[] message)

Methods inherited from class java.lang.Object

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

Field Detail

sets

protected final java.util.HashMap<java.lang.String,InternalTransporter.SubscriptionSet> sets

readLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock writeLock

Constructor Detail

Subscriptions

public Subscriptions()

Method Detail

register

protected void register(java.lang.String channel,
                        InternalTransporter transporter)

deregister

protected void deregister(java.lang.String channel,
                          InternalTransporter transporter,
                          boolean shared)

send

protected void send(java.lang.String channel,
                    byte[] message)
             throws java.lang.Exception

Throws:

java.lang.Exception

getSubscriptionSet

protected InternalTransporter.SubscriptionSet getSubscriptionSet(java.lang.String channel)