Uses of Class
ds.granules.exception.CommunicationsException

Packages that use CommunicationsException

Package	Description
ds.granules.communication
ds.granules.communication.direct
ds.granules.communication.direct.netty.client
ds.granules.communication.direct.netty.server
ds.granules.communication.direct.nio.client
ds.granules.communication.direct.nio.server
ds.granules.communication.funnel
ds.granules.operation	This package encapsulates functionality related to application instances that will be deployed on the cloud.
ds.granules.scheduler	This package contains functionality related to scheduling the application instances.
ds.granules.util	This package contains utility classes used by several components.

Uses of CommunicationsException in ds.granules.communication

Methods in ds.granules.communication that throw CommunicationsException

Modifier and Type	Method and Description
CommFrameworkLauncher	CommFrameworkLauncherFactory.getFrameworkLauncher(Properties props) Get an instance of the framework launcher
void	CommFrameworkLauncher.launch(Properties properties) Launch the framework

Uses of CommunicationsException in ds.granules.communication.direct

Methods in ds.granules.communication.direct that throw CommunicationsException

Modifier and Type	Method and Description
ChannelWriter	ChannelConnector.addNewConnection(String serverHost, int serverPort)
ProgressTracker	JobDeployer.deployOperations(Operation[] operations)
ChannelWriter	ChannelWriterCache.getChannelWriter(String endPoint)
static ZooKeeperAgent	ZooKeeperAgent.getInstance()
static JobDeployer	JobDeployer.getInstance()
static ChannelWriterCache	ChannelWriterCache.getInstance()
void	JobDeployer.initialize(Properties streamingProperties)
void	DirectCommFrameworkLauncher.launch(Properties properties)

Uses of CommunicationsException in ds.granules.communication.direct.netty.client

Methods in ds.granules.communication.direct.netty.client that throw CommunicationsException

Modifier and Type	Method and Description
ChannelWriter	NettyChannelConnector.addNewConnection(String serverHost, int serverPort)

Uses of CommunicationsException in ds.granules.communication.direct.netty.server

Methods in ds.granules.communication.direct.netty.server that throw CommunicationsException

Modifier and Type	Method and Description
void	NettyServerLauncher.launch(Properties properties)

Uses of CommunicationsException in ds.granules.communication.direct.nio.client

Methods in ds.granules.communication.direct.nio.client that throw CommunicationsException

Modifier and Type	Method and Description
ChannelWriter	NIOChannelConnector.addNewConnection(String serverHost, int serverPort)

Uses of CommunicationsException in ds.granules.communication.direct.nio.server

Methods in ds.granules.communication.direct.nio.server that throw CommunicationsException

Modifier and Type	Method and Description
void	NIOServerLauncher.launch(Properties properties)

Uses of CommunicationsException in ds.granules.communication.funnel

Methods in ds.granules.communication.funnel that throw CommunicationsException

Modifier and Type	Method and Description
void	FunnelLauncher.launch(Properties properties)

Uses of CommunicationsException in ds.granules.operation

Methods in ds.granules.operation that throw CommunicationsException

Modifier and Type	Method and Description
void	JobSubmission.abortTask(String jobIdentifier, String taskIdentifier) Send an abort request for a specific task.
ProgressTracker	JobSubmission.deploy(Operation[] operations, int numOfResources, String jobIdentifier, JobLifecycleObserver jobLifecycleObserver)
ProgressTracker	InstanceDeployer.deployOperations(Operation[] operations) This method deploys a set of operations on a specified number of resources.
ProgressTracker	Deployer.deployOperations(Operation[] operations)
ProgressTracker	InstanceDeployer.deployOperations(Operation[] operations, int numOfResources, String jobIdentifier) This method deploys a set of operations on a specified number of resources.
ProgressTracker	InstanceDeployer.deployOperations(Operation[] operations, String jobIdentifier) This method deploys a set of operations on the set of available resources.
void	JobSubmission.discoverResource() Discovers the available computational resources.
void	JobSubmission.discoverResource(int wait) Discovers the available computational resources.
void	JobSubmission.getStatusOfTask(String jobIdentifier, String taskIdentifier) Retrieve the status of a task.
void	InstanceDeployer.initialize(Properties streamingProperties) This initializes the deployer based on the specified argument.
void	Deployer.initialize(Properties streamingProperties)
void	InstanceDeployer.initialize(Properties streamingProperties, String commType) This initializes the deployer based on the specified arguments.
void	JobSubmission.initialize(String configurationFile, int entityId, Properties props, String commType) Initializes communications based on the specified parameters.
void	InstanceDeployer.initialize(String configurationFile, int entityId, Properties props, String commType) This initializes the deployer based on the specified arguments.
void	JobSubmission.killJob(String jobIdentifier) Attempts to kill the job while it is in execution at different sites
void	InstanceDeployer.killJob(String jobIdentifier) Kill a Job with specified jobIdentifer
void	InstanceDeployer.refreshStatus(String jobIdentifier) This method refreshes the status of various tasks that comprise a Job.
void	InstanceDeployer.refreshStatus(String jobIdentifier, String taskIdentifier) This method refreshes the status of a specific task that is part of the Job in question.
ProgressTracker	JobSubmission.submit(Operation operation, JobLifecycleObserver jobLifecycleObserver) Submit the given operation for execution.
ProgressTracker	JobSubmission.submit(Operation operation, String resourceDeploymentStream, JobLifecycleObserver jobLifecycleObserver) Submit the given operation for execution.
ProgressTracker	JobSubmission.submit(Operation operation, String resourceDeploymentStream, String jobIdentifier, JobLifecycleObserver jobLifecycleObserver) This method allows one to group a set of related tasks together in a Job.

Uses of CommunicationsException in ds.granules.scheduler

Methods in ds.granules.scheduler that throw CommunicationsException

Modifier and Type	Method and Description
cgl.narada.service.client.EventConsumer	StreamingService.createConsumer(cgl.narada.service.client.NBEventListener listener) Create an event consumer
cgl.narada.service.client.EventProducer	StreamingService.createProducer() Create a stream producer
cgl.narada.matching.Profile	StreamingService.createProfile(String streamSynopsis, int synopsisType) Create a profile based on the synopsisTypeString and the synopsis
void	Resource.init()
void	ExchangeProcessor.initialize()
void	StreamingService.initialize(String configurationFile, int entityId, Properties props, String commType) Initialize the streaming service based on the specified parameters
void	StreamingService.writeToStream(String streamSynopsis, byte[] payload) Writes a byte[] payload onto the specified stream
void	StreamingService.writeToStream(String streamSynopsis, int synopsisType, byte[] payload) Writes a byte[] payload onto the specified stream

Constructors in ds.granules.scheduler that throw CommunicationsException

Constructor and Description
Diagnostics(String deploymentStream, int numOfThreads)

Uses of CommunicationsException in ds.granules.util

Methods in ds.granules.util that throw CommunicationsException

Modifier and Type	Method and Description
void	StreamPublisher.publishToStream(String publishStream, byte[] transferBytes) Utility method that allows a producer to publish a set of bytes onto the specified stream.