services.moleculer.transporter

Class InternalTransporter.SubscriptionSet

java.lang.Object

services.moleculer.transporter.InternalTransporter.SubscriptionSet

Enclosing class:

InternalTransporter

protected static class InternalTransporter.SubscriptionSet
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	channel
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	readLock
protected java.util.WeakHashMap<InternalTransporter,InternalTransporter>	set
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	writeLock

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SubscriptionSet(java.lang.String channel)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

set

protected final java.util.WeakHashMap<InternalTransporter,InternalTransporter> set

readLock

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

writeLock

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

channel

protected final java.lang.String channel

Constructor Detail

SubscriptionSet

protected SubscriptionSet(java.lang.String channel)

Method Detail

register

protected void register(InternalTransporter transporter)

deregister

protected void deregister(InternalTransporter transporter)

send

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

Throws:

java.lang.Exception