Options
All
  • Public
  • Public/Protected
  • All
Menu

Class TopicRouting

Routing the incoming messages to the correct handler

Hierarchy

  • TopicRouting

Index

Constructors

constructor

  • Create a new TopicRouting instance

    Parameters

    • errorHandler: ErrorHandler

      the error handler

    • serviceAdapter: ServiceAdapter

      the service adapter that will receive service requests, responses and errors

    • conversationSet: ConversationSet

      the conversation set that handles fetch replies

    • cache: TopicCache

      the topic cache that handles topic values and deltas

    • registry: StreamRegistryImpl

      the stream registry that is passed on to the topic cache

    Returns TopicRouting

Properties

Private cache

cache: TopicCache

The topic cache that handles topic values and deltas

Private conversationSet

conversationSet: ConversationSet

The conversation set that handles fetch replies

Private errorHandler

errorHandler: ErrorHandler

The error handler

Private registry

The stream registry that is passed on to the topic cache

Private serviceAdapter

serviceAdapter: ServiceAdapter

The service adapter that will receive service requests, responses and errors

Methods

route

  • Route a message to the correct handler

    Parameters

    • message: Message

      the incoming message that needs to be handled

    Returns void

subscribe

  • Subscribe to a new topic

    Parameters

    Returns void

unsubscribe

  • Unsubscribe from a topic

    Parameters

    • id: number

      the topic id to unsubscribe from

    • reason: UnsubscribeReason

      the reason for unsubscribing

    Returns void