Class InternalTransporter.Subscriptions

java.lang.Object

services.moleculer.transporter.InternalTransporter.Subscriptions

Enclosing class:

InternalTransporter

public static class InternalTransporter.Subscriptions
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReentrantReadWriteLock.ReadLock	readLock
protected final HashMap<String, InternalTransporter.SubscriptionSet>	sets
protected final ReentrantReadWriteLock.WriteLock	writeLock

Constructor Summary

Constructors

Constructor	Description
Subscriptions()

Method Summary

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

Methods inherited from class Object

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

Field Details

sets

protected final HashMap<String, InternalTransporter.SubscriptionSet> sets

readLock

protected final ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final ReentrantReadWriteLock.WriteLock writeLock

Constructor Details

Subscriptions

public Subscriptions()

Method Details

register

protected void register(String channel,
 InternalTransporter transporter)

deregister

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

send

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

Throws:

Exception

getSubscriptionSet

protected InternalTransporter.SubscriptionSet getSubscriptionSet(String channel)