org.gradle.messaging.remote.internal

Class MessagingServices

java.lang.Object

org.gradle.internal.service.DefaultServiceRegistry

org.gradle.messaging.remote.internal.MessagingServices

All Implemented Interfaces:

ServiceRegistry, Stoppable

public class MessagingServices
extends DefaultServiceRegistry
implements Stoppable

A factory for a set of messaging services. Provides the following services:

• MessagingClient
• MessagingServer
• OutgoingBroadcast
• IncomingBroadcast

Constructor Summary

Constructors

Constructor and Description
MessagingServices(ClassLoader messageClassLoader)
MessagingServices(ClassLoader messageClassLoader, String broadcastGroup)
MessagingServices(ClassLoader messageClassLoader, String broadcastGroup, SocketInetAddress broadcastAddress)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes all services for this registry.
protected ExecutorFactory	createExecutorFactory()
protected IncomingBroadcast	createIncomingBroadcast()
protected IncomingConnector<Message>	createIncomingConnector()
protected MessageOriginator	createMessageOriginator()
protected MessagingClient	createMessagingClient()
protected MessagingServer	createMessagingServer()
protected AsyncConnection<DiscoveryMessage>	createMulticastConnection()
protected MultiChannelConnector	createMultiChannelConnector()
protected OutgoingBroadcast	createOutgoingBroadcast()
protected OutgoingConnector<Message>	createOutgoingConnector()
void	stop() Requests a graceful stop of this object.

Methods inherited from class org.gradle.internal.service.DefaultServiceRegistry

add, add, get, getFactory, newInstance, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MessagingServices

public MessagingServices(ClassLoader messageClassLoader)

MessagingServices

public MessagingServices(ClassLoader messageClassLoader,
                 String broadcastGroup)

MessagingServices

public MessagingServices(ClassLoader messageClassLoader,
                 String broadcastGroup,
                 SocketInetAddress broadcastAddress)

Method Detail

stop

public void stop()

Description copied from interface: Stoppable

Requests a graceful stop of this object. Blocks until all concurrent activity has been completed.

If this object has already been stopped, this method does nothing.

Specified by:

stop in interface Stoppable

close

public void close()

Description copied from class: DefaultServiceRegistry

Closes all services for this registry. For each service, if the service has a public void close() method, that method is called to close the service.

Overrides:

close in class DefaultServiceRegistry

createMessageOriginator

protected MessageOriginator createMessageOriginator()

createExecutorFactory

protected ExecutorFactory createExecutorFactory()

createOutgoingConnector

protected OutgoingConnector<Message> createOutgoingConnector()

createIncomingConnector

protected IncomingConnector<Message> createIncomingConnector()

createMultiChannelConnector

protected MultiChannelConnector createMultiChannelConnector()

createMessagingClient

protected MessagingClient createMessagingClient()

createMessagingServer

protected MessagingServer createMessagingServer()

createIncomingBroadcast

protected IncomingBroadcast createIncomingBroadcast()

createOutgoingBroadcast

protected OutgoingBroadcast createOutgoingBroadcast()

createMulticastConnection

protected AsyncConnection<DiscoveryMessage> createMulticastConnection()