YOUnite Adaptor Guide for Java Developers

Adaptor design

Adaptor Components

Adaptor Lifecycle

1. Adaptor registration
2. Adaptor start up: When an Adaptor process comes up, as part of the handshake, it sends an Adaptor ready message to the router. For example:
   

   //Create MessageServiceConfiguration builder to
   //build MessageServiceConfiguration
   //Use
   MessageServiceConfiguration.Builder builder = MessageServiceConfiguration.newConfiguration();

   MessageServiceConfiguration msConf = builder.setBrokerUrl("nio+ssl://docker.local:61617"). setJmsClientId(jmsClientId).build();

   try {
   MessageService messageService = MessageServiceFactory.getMessageService(msConf);

   messageService.setListener(Constants.MessageType.OPS, adminListener); <-- Listener for OPS messages
   messageService.setListener(Constants.MessageType.DATA, dataListener); <-- Listener for Data messages

   AdaptorUp adaptorUp = new AdaptorUp();
   adaptorUp.setStatus("RUNNING");
   Map<String, String> capabilities = new HashMap<>();
   //Add capabilities list
   adaptorUp.setCapabilities(capabilities);
   ObjectMapper objectMapper = new ObjectMapper();
   objectMapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
   String upMessage = objectMapper.writeValueAsString(adaptorUp);
   //Send an OPS message

   messageService.sendMessage(Constants.MessageType.OPS, upMessage);  <-- Send Adaptor Up on OPS channel.

   //If everything goes fine, the router sends a message on OPS announcing the state of this Adaptor.

   //If there is a problem, then the dataListener is notified of the error message.