Interface CommonConnectionManager

All Known Subinterfaces:
CenterConnectionManager, ConnectionManager
All Known Implementing Classes:
DefaultConnectionManager
public interface CommonConnectionManager
Manages Aeron publications and fragment polling for common network connections.
Since:
25.1
Author:
渔民小镇
date:
2025-10-25

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    containsNetId(int netId)
    Tests whether a publication mapping exists for the given network id.
    io.aeron.Publication
    getPublicationByNetId(int netId)
    Gets the Aeron publication bound to the given network id.
    int
    poll(io.aeron.logbuffer.FragmentHandler fragmentHandler)
    Polls inbound fragments and dispatches them to the provided fragment handler.
    void
    publishMessage(String pubName, Object message)
    Publishes a message through the named publication pipeline.

  • Method Details

    • containsNetId

      boolean containsNetId(int netId)
      Tests whether a publication mapping exists for the given network id.
      Parameters:
      netId - network id
      Returns:
      true if the mapping exists

    • getPublicationByNetId

      io.aeron.Publication getPublicationByNetId(int netId)
      Gets the Aeron publication bound to the given network id.
      Parameters:
      netId - network id
      Returns:
      publication, or null if absent

    • publishMessage

      void publishMessage(String pubName, Object message)
      Publishes a message through the named publication pipeline.
      Parameters:
      pubName - publication name
      message - message to publish

    • poll

      int poll(io.aeron.logbuffer.FragmentHandler fragmentHandler)
      Polls inbound fragments and dispatches them to the provided fragment handler.
      Parameters:
      fragmentHandler - fragment callback
      Returns:
      number of fragments processed