org.jboss.as.host.controller

Class RemoteDomainConnectionService

java.lang.Object

org.jboss.as.host.controller.RemoteDomainConnectionService

All Implemented Interfaces:

Closeable, AutoCloseable, ModelControllerClient, MasterDomainControllerClient, org.jboss.msc.service.Service<MasterDomainControllerClient>, org.jboss.msc.value.Value<MasterDomainControllerClient>

public class RemoteDomainConnectionService
extends Object
implements MasterDomainControllerClient, org.jboss.msc.service.Service<MasterDomainControllerClient>

Establishes the connection from a slave DomainController to the master DomainController

Author:

Kabir Khan

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.as.controller.client.ModelControllerClient

ModelControllerClient.Factory

Field Summary

Fields

Modifier and Type	Field and Description
static String	DOMAIN_CONNECTION_ID

Fields inherited from interface org.jboss.as.host.controller.MasterDomainControllerClient

SERVICE_NAME

Fields inherited from interface org.jboss.msc.service.Service

NULL, NULL_VALUE

Method Summary

Modifier and Type	Method and Description
void	close()
org.jboss.dmr.ModelNode	execute(org.jboss.dmr.ModelNode operation) Execute an operation synchronously.
org.jboss.dmr.ModelNode	execute(org.jboss.dmr.ModelNode operation, OperationMessageHandler messageHandler) Execute an operation synchronously, optionally receiving progress reports.
org.jboss.dmr.ModelNode	execute(Operation operation) Execute an operation synchronously.
org.jboss.dmr.ModelNode	execute(Operation operation, OperationMessageHandler messageHandler) Execute an operation synchronously, optionally receiving progress reports.
org.jboss.threads.AsyncFuture<org.jboss.dmr.ModelNode>	executeAsync(org.jboss.dmr.ModelNode operation, OperationMessageHandler messageHandler) Execute an operation in another thread, optionally receiving progress reports.
org.jboss.threads.AsyncFuture<org.jboss.dmr.ModelNode>	executeAsync(Operation operation, OperationMessageHandler messageHandler) Execute an operation in another thread, optionally receiving progress reports.
OperationResponse	executeOperation(Operation operation, OperationMessageHandler messageHandler) Execute an operation synchronously, optionally receiving progress reports, with the response to the operation making available any input streams that the server may associate with the response.
org.jboss.threads.AsyncFuture<OperationResponse>	executeOperationAsync(Operation operation, OperationMessageHandler messageHandler) Execute an operation in another thread, optionally receiving progress reports, with the response to the operation making available any input streams that the server may associate with the response.
void	fetchAndSyncMissingConfiguration(OperationContext context, Resource original) Pulls down missing data from the domain controller and applies it to the local model as a result of a change to a/an added server-config
void	fetchDomainWideConfiguration() Connect to the remote domain controller and fetch the domain wide configuration, but do not register as a member of the domain.
HostFileRepository	getRemoteFileRepository() Gets a HostFileRepository capable of retrieving files from the master domain controller.
MasterDomainControllerClient	getValue()
void	register() Register with the remote domain controller
void	start(org.jboss.msc.service.StartContext context)
void	stop(org.jboss.msc.service.StopContext context)
void	unregister() Unregister with the remote domain controller.

Methods inherited from class java.lang.Object

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

Field Detail

DOMAIN_CONNECTION_ID

public static final String DOMAIN_CONNECTION_ID

See Also:

Constant Field Values

Method Detail

register

public void register()
              throws IOException

Register with the remote domain controller

Specified by:

register in interface MasterDomainControllerClient

Throws:

IOException - if there was a problem talking to the remote host

unregister

public void unregister()

Unregister with the remote domain controller.

Specified by:

unregister in interface MasterDomainControllerClient

fetchDomainWideConfiguration

public void fetchDomainWideConfiguration()

Description copied from interface: MasterDomainControllerClient

Connect to the remote domain controller and fetch the domain wide configuration, but do not register as a member of the domain.

Specified by:

fetchDomainWideConfiguration in interface MasterDomainControllerClient

getRemoteFileRepository

public HostFileRepository getRemoteFileRepository()

Gets a HostFileRepository capable of retrieving files from the master domain controller.

Specified by:

getRemoteFileRepository in interface MasterDomainControllerClient

Returns:

the file repository

execute

public org.jboss.dmr.ModelNode execute(org.jboss.dmr.ModelNode operation)
                                throws IOException

Description copied from interface: ModelControllerClient

Execute an operation synchronously.

Specified by:

execute in interface ModelControllerClient

Parameters:

operation - the operation to execute

Returns:

the result of the operation

Throws:

IOException - if an I/O error occurs while executing the operation

execute

public org.jboss.dmr.ModelNode execute(Operation operation)
                                throws IOException

Description copied from interface: ModelControllerClient

Execute an operation synchronously. Note that associated input-streams have to be closed by the caller, after the operation completed OperationAttachments.isAutoCloseStreams().

Specified by:

execute in interface ModelControllerClient

Parameters:

operation - the operation to execute

Returns:

the result of the operation

Throws:

IOException - if an I/O error occurs while executing the operation

execute

public org.jboss.dmr.ModelNode execute(org.jboss.dmr.ModelNode operation,
                                       OperationMessageHandler messageHandler)
                                throws IOException

Description copied from interface: ModelControllerClient

Execute an operation synchronously, optionally receiving progress reports.

Specified by:

execute in interface ModelControllerClient

Parameters:

operation - the operation to execute

messageHandler - the message handler to use for operation progress reporting, or null for none

Returns:

the result of the operation

Throws:

IOException - if an I/O error occurs while executing the operation

execute

public org.jboss.dmr.ModelNode execute(Operation operation,
                                       OperationMessageHandler messageHandler)
                                throws IOException

Description copied from interface: ModelControllerClient

Execute an operation synchronously, optionally receiving progress reports.

Note that associated input-streams have to be closed by the caller, after the operation completed OperationAttachments.isAutoCloseStreams().

Specified by:

execute in interface ModelControllerClient

Parameters:

operation - the operation to execute

messageHandler - the message handler to use for operation progress reporting, or null for none

Returns:

the result of the operation

Throws:

IOException - if an I/O error occurs while executing the operation

executeAsync

public org.jboss.threads.AsyncFuture<org.jboss.dmr.ModelNode> executeAsync(org.jboss.dmr.ModelNode operation,
                                                                           OperationMessageHandler messageHandler)

Description copied from interface: ModelControllerClient

Execute an operation in another thread, optionally receiving progress reports.

Specified by:

executeAsync in interface ModelControllerClient

Parameters:

operation - the operation to execute

messageHandler - the message handler to use for operation progress reporting, or null for none

Returns:

the future result of the operation

executeAsync

public org.jboss.threads.AsyncFuture<org.jboss.dmr.ModelNode> executeAsync(Operation operation,
                                                                           OperationMessageHandler messageHandler)

Description copied from interface: ModelControllerClient

Execute an operation in another thread, optionally receiving progress reports.

Note that associated input-streams have to be closed by the caller, after the operation completed OperationAttachments.isAutoCloseStreams().

Specified by:

executeAsync in interface ModelControllerClient

Parameters:

operation - the operation to execute

messageHandler - the message handler to use for operation progress reporting, or null for none

Returns:

the future result of the operation

executeOperation

public OperationResponse executeOperation(Operation operation,
                                          OperationMessageHandler messageHandler)
                                   throws IOException

Description copied from interface: ModelControllerClient

Execute an operation synchronously, optionally receiving progress reports, with the response to the operation making available any input streams that the server may associate with the response.

Note that associated input-streams have to be closed by the caller, after the operation completed OperationAttachments.isAutoCloseStreams().

Specified by:

executeOperation in interface ModelControllerClient

Parameters:

operation - the operation to execute

messageHandler - the message handler to use for operation progress reporting, or null for none

Returns:

the result of the operation

Throws:

IOException - if an I/O error occurs while executing the operation

executeOperationAsync

public org.jboss.threads.AsyncFuture<OperationResponse> executeOperationAsync(Operation operation,
                                                                              OperationMessageHandler messageHandler)

Description copied from interface: ModelControllerClient

Execute an operation in another thread, optionally receiving progress reports, with the response to the operation making available any input streams that the server may associate with the response.

Note that associated input-streams have to be closed by the caller, after the operation completed OperationAttachments.isAutoCloseStreams().

Specified by:

executeOperationAsync in interface ModelControllerClient

Parameters:

operation - the operation to execute

messageHandler - the message handler to use for operation progress reporting, or null for none

Returns:

the future result of the operation

fetchAndSyncMissingConfiguration

public void fetchAndSyncMissingConfiguration(OperationContext context,
                                             Resource original)
                                      throws OperationFailedException

Description copied from interface: MasterDomainControllerClient

Pulls down missing data from the domain controller and applies it to the local model as a result of a change to a/an added server-config

Specified by:

fetchAndSyncMissingConfiguration in interface MasterDomainControllerClient

Parameters:

context - the operation context

Throws:

OperationFailedException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

start

public void start(org.jboss.msc.service.StartContext context)
           throws org.jboss.msc.service.StartException

Specified by:

start in interface org.jboss.msc.service.Service<MasterDomainControllerClient>

Throws:

org.jboss.msc.service.StartException

stop

public void stop(org.jboss.msc.service.StopContext context)

Specified by:

stop in interface org.jboss.msc.service.Service<MasterDomainControllerClient>

getValue

public MasterDomainControllerClient getValue()
                                      throws IllegalStateException,
                                             IllegalArgumentException

Specified by:

getValue in interface org.jboss.msc.value.Value<MasterDomainControllerClient>

Throws:

IllegalStateException

IllegalArgumentException