@Test(expected = ProviderCreationException.class) public void testInvalidSSLConfiguration() throws Exception { testRunner.setProperty(AbstractAMQPProcessor.USE_CERT_AUTHENTICATION, "true"); testRunner.setProperty(AbstractAMQPProcessor.HOST, "test"); testRunner.setProperty(AbstractAMQPProcessor.PORT, "9999"); testRunner.setProperty(AbstractAMQPProcessor.USER, "test"); testRunner.setProperty(AbstractAMQPProcessor.PASSWORD, "test"); processor.onTrigger(testRunner.getProcessContext(), testRunner.getProcessSessionFactory()); }
@Override public final void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { AMQPResource<T> resource = resourceQueue.poll(); if (resource == null) { resource = createResource(context); } try { processResource(resource.getConnection(), resource.getWorker(), context, session); resourceQueue.offer(resource); } catch (final Exception e) { try { resource.close(); } catch (final Exception e2) { e.addSuppressed(e2); } throw e; } }
AbstractAMQPProcessor extends AbstractProcessor { @Override public final void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { AMQPResource<T> resource = resourceQueue.poll(); if (resource == null) { resource = createResource(context); } try { processResource(resource.getConnection(), resource.getWorker(), context, session); resourceQueue.offer(resource); } catch (final Exception e) { try { resource.close(); } catch (final Exception e2) { e.addSuppressed(e2); } throw e; } } }
AbstractAMQPProcessor extends AbstractProcessor { @Override public final void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { AMQPResource<T> resource = resourceQueue.poll(); if (resource == null) { resource = createResource(context); } try { processResource(resource.getConnection(), resource.getWorker(), context, session); resourceQueue.offer(resource); } catch (final Exception e) { try { resource.close(); } catch (final Exception e2) { e.addSuppressed(e2); } throw e; } }  }
AbstractAMQPProcessor extends AbstractProcessor { @Override public final void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { AMQPResource<T> resource = resourceQueue.poll(); if (resource == null) { resource = createResource(context); } try { processResource(resource.getConnection(), resource.getWorker(), context, session); resourceQueue.offer(resource); } catch (final Exception e) { try { resource.close(); } catch (final Exception e2) { e.addSuppressed(e2); } throw e; } }  @Override final void onTrigger(final ProcessContext context, final ProcessSession session); @OnStopped void close(); }
AbstractAMQPProcessor extends AbstractProcessor { @Override public final void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException { AMQPResource<T> resource = resourceQueue.poll(); if (resource == null) { resource = createResource(context); } try { processResource(resource.getConnection(), resource.getWorker(), context, session); resourceQueue.offer(resource); } catch (final Exception e) { try { resource.close(); } catch (final Exception e2) { e.addSuppressed(e2); } throw e; } }  @Override final void onTrigger(final ProcessContext context, final ProcessSession session); @OnStopped void close(); static final PropertyDescriptor HOST; static final PropertyDescriptor PORT; static final PropertyDescriptor V_HOST; static final PropertyDescriptor USER; static final PropertyDescriptor PASSWORD; static final PropertyDescriptor AMQP_VERSION; static final PropertyDescriptor SSL_CONTEXT_SERVICE; static final PropertyDescriptor USE_CERT_AUTHENTICATION; static final PropertyDescriptor CLIENT_AUTH; }