jms-spec
  1. jms-spec
  2. JMS_SPEC-107

Extend connection consumer API to support shared durable and non-durable subscriptions

    Details

    • Type: New Feature New Feature
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: 2.0PD
    • Fix Version/s: 2.0PD, 2.0
    • Labels:
      None

      Description

      Now that JMS_SPEC-40 has added shared-durable and non-durable subscriptions to JMS, the connection consumer API needs to be extended to support them.

      So in addition to the existing methods on Connection:

      ConnectionConsumer createConnectionConsumer(
         Destination destination, String messageSelector, ServerSessionPool sessionPool, 
         int maxMessages)
      

      (Queues or unshared non-durable topic subscriptions, clientId optional)

      ConnectionConsumer createDurableConnectionConsumer(
         Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, 
         int maxMessages)
      

      (Unshared durable topic subscriptions, clientId required)

      we also need

      ConnectionConsumer createSharedConnectionConsumer(
         Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, 
         int maxMessages)
      

      (Shared non-durable topic subscriptions, clientId optional)

      ConnectionConsumer createSharedDurableConnectionConsumer(
         Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, 
         int maxMessages)
      

      (Shared durable topic subscriptions, clientId optional)

        Issue Links

          Activity

          No work has yet been logged on this issue.

            People

            • Assignee:
              Nigel Deakin
              Reporter:
              Nigel Deakin
            • Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: