Ability to supply a prefix for watches. Fixed ordered consumer naming bug.

[scottf]

Overview

• Original Ordered Push Consumers that can supply a name, but that name is used as a prefix.
• Key Value and Object Store watchers can supply a consumer name prefix via their implementation of Watcher
• Simplified ordered consumers can supply a consumer name prefix in OrderedConsumerConfiguration

Per file change Notes

These files only changes are api documentation or comment cleanup.

• BaseConsumeOptions.java
• BaseConsumerContext.java
• KeyValueManagement.java
• MessageConsumer.java
• SubscribeOptions.java

OrderedConsumerConfiguration.java

• is mostly documentation but one important api change, the addition of
  • public OrderedConsumerConfiguration consumerNamePrefix(String consumerNamePrefix)

Watcher.java

• adds a new interface method with a default. This is what allows a KV or OS watcher to supply a prefix.
  • default String getConsumerNamePrefix()

NatsConsumerContext.java

• applies the consumerNamePrefix from the OrderedConsumerConfiguration
• records the consumer name in the context
• updates the behavior of the next(...) implementation to record the consumer name

NatsJetStream.java

• Code here now is ordered aware. When ordered, it automatically changes a consumer name into a prefix and makes sure that name is used to create the physical consumer. This is the code that actually creates a consumer on subscribe so this change will affect all ordered consumers.

NatsJetStreamImpl.java

• simplified consumerConfigurationForOrdered, recognizing the change in NatsJetStream

NatsKeyValueWatchSubscription.java and NatsObjectStoreWatchSubscription.java

• passes the prefix to code that completes initialization of the watcher

NatsMessageConsumerBase.java

• properly manages the knowledge of the consumer name in simplification

NatsWatchSubscription.java

• uses the consumer name prefix as the consumer config name, which NatsJetStream turns into a prefix now that it is ordered aware

OrderedMessageManager.java

• remove code to delete an existing consumer, since this can fail. Not needed anymore since NatsJetStream ensures a unique name for all ordered consumers.

PushMessageManager.java

• renamed a variable - nothing functional

NatsJetStreamUtil.java

• New class - currently has helper functions to create consumer names

Tests

• JetStreamConsumerTests.java
• JetStreamGeneralTests.java
• KeyValueTests.java
• SimplificationTests.java
• TestBase.java