services.moleculer.transporter

Class InternalTransporter.Subscriptions

java.lang.Object

services.moleculer.transporter.InternalTransporter.Subscriptions

Enclosing class:

InternalTransporter

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

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.StampedLock	lock
protected Serializer	serializer
protected java.util.HashMap<java.lang.String,InternalTransporter.SubscriptionSet>	sets

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Subscriptions(Serializer serializer)

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, io.datatree.Tree 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

lock

protected final java.util.concurrent.locks.StampedLock lock

serializer

protected final Serializer serializer

Constructor Detail

Subscriptions

protected Subscriptions(Serializer serializer)

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,
                    io.datatree.Tree message)
             throws java.lang.Exception

Throws:

java.lang.Exception

getSubscriptionSet

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