Class InternalTransporter.SubscriptionSet

java.lang.Object

services.moleculer.transporter.InternalTransporter.SubscriptionSet

Enclosing class:

InternalTransporter

protected static class InternalTransporter.SubscriptionSet
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	channel
protected final ReentrantReadWriteLock.ReadLock	readLock
protected final WeakHashMap<InternalTransporter, InternalTransporter>	set
protected final ReentrantReadWriteLock.WriteLock	writeLock

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SubscriptionSet(String channel)

Method Summary

Modifier and Type	Method	Description
protected void	deregister(InternalTransporter transporter)
protected void	register(InternalTransporter transporter)
protected void	send(byte[] message)

Methods inherited from class Object

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

Field Details

set

protected final WeakHashMap<InternalTransporter, InternalTransporter> set

readLock

protected final ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final ReentrantReadWriteLock.WriteLock writeLock

channel

protected final String channel

Constructor Details

SubscriptionSet

protected SubscriptionSet(String channel)

Method Details

register

protected void register(InternalTransporter transporter)

deregister

protected void deregister(InternalTransporter transporter)

send

protected void send(byte[] message)
             throws Exception

Throws:

Exception