jayeson.lib.delivery v1.0.5

v 1.1.2

• Use StreamFinder 1.2.3
• Use Netty 4.0.36.Final
• Support multiple scopes in subscriber(Update subscriber config.Will not work with older config)
• Fixed Reconnection bug in Subscriber where reconnection trying stops after some retries
• Remove StreamRegistry Group Processing from Eventloop.(No change is needed in PE)
  • To Describing PE callback behavoiur more explcitly:
    • PE should expect messages from an endpoint AFTER call of actOnStreamRegistrationRequest()
    • PE should initiate sending messages ONLY afte call of startPublishing()
• Subscriber now dont make unnecessary connection to StreamFinder if application is not using subscriber module(i.e If no discovery streams in config).
• Exposed default handlers in JsonBaseMessageClass. Applications can now extend JSonBaseMessageClass to do custom transformation of message within pipeline itself. E:g here
• Added Abstrations for using with jruby
• Minor bug fixes and improved logging

Registered MessageGroups. Please register your message group before using on common infrastructure

Develeoper Notes

We follow google java style guide
https://google.github.io/styleguide/javaguide.html

Few Points to take note(Copied from style guide ):

4.1 Braces

4.1.1 Braces are used where optional

Braces are used with if, else, for, do and while statements, even when the body is empty or contains only a single statement.

4.1.2 Nonempty blocks: K & R style

Braces follow the Kernighan and Ritchie style ("Egyptian brackets") for nonempty blocks and block-like constructs:

No line break before the opening brace.
Line break after the opening brace.
Line break before the closing brace.
Line break after the closing brace if that brace terminates a statement or the body of a method, constructor or named class. For example, there is no line break after the brace if it is followed by else or a comma.

Example:

  @Override public void method() {
    if (condition()) {
      try {
        something();
      } catch (ProblemException e) {
        recover();
      }
    }
  }
};```