public void endpointActivation()

in chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java [104:133]

23 lines of code
2 McCabe index (conditional complexity)


    public void endpointActivation(final MessageEndpointFactory messageEndpointFactory, final ActivationSpec activationSpec)
            throws ResourceException {
        final NATSActivationSpec NATSActivationSpec = (NATSActivationSpec) activationSpec;

        workManager.scheduleWork(new Work() {

            @Override
            public void run() {
                try {
                    final MessageEndpoint messageEndpoint = messageEndpointFactory.createEndpoint(null);

                    final EndpointTarget target = new EndpointTarget(messageEndpoint);
                    targets.put(NATSActivationSpec, target);

                    final Subscription subscription = connection.subscribe(((NATSActivationSpec) activationSpec).getSubject(), target, 
                    		new SubscriptionOptions.Builder().startWithLastReceived().manualAcks().ackWait(Duration.ofSeconds(Integer.parseInt(((NATSActivationSpec) activationSpec).getAckWait())))
                            .durableName(((NATSActivationSpec) activationSpec).getDurableName()).build());
                    target.setSubscription(subscription);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }

            @Override
            public void release() {
            }

        });

    }