HHH-10006 - Document configuration of JndiService;

HHH-10007 - Audit Services chapter in Integrations Guide

Author: sebersole

documentation/src/main/docbook/integration/en-US/chapters/services/Services.xml

@@ -0,0 +1,11 @@
+public class DisabledEventPublishingServiceImpl implements EventPublishingService {
+	public static DisabledEventPublishingServiceImpl INSTANCE = new DisabledEventPublishingServiceImpl();
+
+	private DisabledEventPublishingServiceImpl() {
+	}
+
+	@Override
+	public void publish(Event theEvent) {
+		// nothing to do...
+	}
+}

documentation/src/main/docbook/integration/en-US/chapters/services/extras/extend/DisabledEventPublishingServiceImpl.java

@@ -0,0 +1,3 @@
+public interface EventPublishingService extends Service {
+	public void publish(Event theEvent);
+}

documentation/src/main/docbook/integration/en-US/chapters/services/extras/extend/EventPublishingService.java

@@ -0,0 +1,12 @@
+public class EventPublishingServiceContributor
+		implements ServiceContributor {
+	@Override
+	public void contribute(StandardServiceRegistryBuilder builder) {
+		builder.addInitiator( EventPublishingServiceInitiator.INSTANCE );
+
+		// if we wanted to allow other strategies (e.g. a JMS
+		// Queue publisher) we might also register short names
+		// here with the StrategySelector.  The initiator would
+		// then need to accept the strategy as a config setting
+	}
+}

documentation/src/main/docbook/integration/en-US/chapters/services/extras/extend/EventPublishingServiceContributor.java

@@ -0,0 +1,50 @@
+public class EventPublishingServiceImpl
+		implements EventPublishingService,
+				Configurable,
+				Startable,
+				Stoppable,
+				ServiceRegistryAwareService {
+
+	private ServiceRegistryImplementor serviceRegistry;
+	private String jmsConnectionFactoryName;
+	private String destinationName;
+
+	private Connection jmsConnection;
+	private Session jmsSession;
+	private MessageProducer publisher;
+
+	@Override
+	public void injectServices(ServiceRegistryImplementor serviceRegistry) {
+		this.serviceRegistry = serviceRegistry;
+	}
+
+	public void configure(Map configurationValues) {
+		this.jmsConnectionFactoryName = configurationValues.get( JMS_CONNECTION_FACTORY_NAME_SETTING );
+		this.destinationName = configurationValues.get( JMS_DESTINATION_NAME_SETTING );
+	}
+
+	@Override
+	public void start() {
+		final JndiService jndiService = serviceRegistry.getService( JndiService.class );
+		final ConnectionFactory jmsConnectionFactory = jndiService.locate( jmsConnectionFactoryName );
+
+		this.jmsConnection = jmsConnectionFactory.createConnection();
+		this.jmsSession = jmsConnection.createSession( true,  Session.AUTO_ACKNOWLEDGE );
+
+		final Destination destination = jndiService.locate( destinationName );
+
+		this.publisher = jmsSession.createProducer( destination );
+	}
+
+	@Override
+	public void publish(Event theEvent) {
+		publisher.send( theEvent );
+	}
+
+	@Override
+	public void stop() {
+		publisher.close();
+		jmsSession.close();
+		jmsConnection.close();
+	}
+}

documentation/src/main/docbook/integration/en-US/chapters/services/extras/extend/EventPublishingServiceImpl.java

@@ -0,0 +1,22 @@
+public class EventPublishingServiceInitiator implements StandardServiceInitiator<EventPublishingService> {
+	public static EventPublishingServiceInitiator INSTANCE = new EventPublishingServiceInitiator();
+	public static final String ENABLE_PUBLISHING_SETTING = "com.acme.EventPublishingService.enabled";
+
+	@Override
+	public Class<R> getServiceInitiated() {
+		return EventPublishingService.class;
+	}
+
+	@Override
+	public R initiateService(Map configurationValues, ServiceRegistryImplementor registry) {
+		final boolean enabled = extractBoolean( configurationValues, ENABLE_PUBLISHING_SETTING );
+		if ( enabled ) {
+			return new EventPublishingServiceImpl();
+		}
+		else {
+			return DisabledEventPublishingServiceImpl.INSTANCE;
+		}
+	}
+
+	...
+}

documentation/src/main/docbook/integration/en-US/chapters/services/extras/extend/EventPublishingServiceInitiator.java

@@ -0,0 +1,55 @@
+import java.lang.Override;
+
+public class LatestAndGreatestConnectionProviderImpl
+		implements ConnectionProvider, Startable, Stoppable, Configurable {
+
+	private LatestAndGreatestPoolBuilder lagPoolBuilder;
+	private LatestAndGreatestPool lagPool;
+	private boolean available = false;
+
+	@Override
+	public void configure(Map configurationValues) {
+		// extract our config from the settings map
+		lagPoolBuilder = buildBuilder( configurationValues );
+	}
+
+	@Override
+	public void start() {
+		// start the underlying pool
+		lagPool = lagPoolBuilder.buildPool();
+
+		available = true;
+	}
+
+	@Override
+	public void stop() {
+		available = true;
+
+		// stop the underlying pool
+		lagPool.shutdown();
+	}
+
+	@Override
+	public Connection getConnection() throws SQLException {
+		if ( !available ) {
+			throwException( "LatestAndGreatest ConnectionProvider not available for use" )
+		}
+
+		return lagPool.borrowConnection();
+	}
+
+	@Override
+	public void closeConnection(Connection conn) throws SQLException {
+		if ( !available ) {
+			warn( "LatestAndGreatest ConnectionProvider not available for use" )
+		}
+
+		if ( conn == null ) {
+			return;
+		}
+
+		lagPool.releaseConnection( conn );
+	}
+
+	...
+}

documentation/src/main/docbook/integration/en-US/chapters/services/extras/override/LatestAndGreatestConnectionProviderImpl.java

@@ -0,0 +1,7 @@
+StandardServiceRegistryBuilder builder = ...;
+...
+builder.addService(
+		ConnectionProvider.class,
+		new LatestAndGreatestConnectionProviderImpl()
+);
+...

documentation/src/main/docbook/integration/en-US/chapters/services/extras/override/ex1-direct.java

@@ -0,0 +1,10 @@
+public class LatestAndGreatestConnectionProviderImplContributor1
+		implements ServiceContributor {
+	@Override
+	public void contribute(StandardServiceRegistryBuilder serviceRegistryBuilder) {
+		serviceRegistryBuilder.addService(
+				ConnectionProvider.class,
+				new LatestAndGreatestConnectionProviderImpl()
+		);
+	}
+}

documentation/src/main/docbook/integration/en-US/chapters/services/extras/override/ex2-contributor.java

@@ -0,0 +1 @@
+fully.qualified.package.LatestAndGreatestConnectionProviderImplContributor1