org.codice.ddf.sdk.cometd

Class AsyncClient

java.lang.Object

org.codice.ddf.sdk.cometd.AsyncClient

public class AsyncClient
extends Object

This class is used to establish a session with the DDF cometd api. It provides the capability to monitor notifications, activities as well as the ability to issue queries and download products.

Constructor Summary

Constructors

Constructor and Description
AsyncClient(String url, Boolean disableValidation) Creates a ddf async client with default channel subscriptions

Method Summary

Modifier and Type	Method and Description
void	checkAllActivities() Retrieves all persisted activities.
void	checkAllNotifications() Retrieves all persisted notification.
void	checkDownloadNotifications() Retrieves download notifications
void	downloadById(String catalogId, String sourceName) Initiate download of a product.
Map<String,Object>	getActivities() Get all activities messages
Map<String,Object>	getNotifications() Get all notification messages
Map<String,Object>	getQueryResponse() Get all query response messages

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncClient

public AsyncClient(String url,
                   Boolean disableValidation)
            throws Exception

Creates a ddf async client with default channel subscriptions

Parameters:

url - - target ddf url

disableValidation - - disable ssl hostname validation

Throws:

Exception

Method Detail

getNotifications

public Map<String,Object> getNotifications()

Get all notification messages

Returns:

- notifications map

getActivities

public Map<String,Object> getActivities()

Get all activities messages

Returns:

- activities map

getQueryResponse

public Map<String,Object> getQueryResponse()

Get all query response messages

Returns:

- query response map

checkAllNotifications

public void checkAllNotifications()

Retrieves all persisted notification. The notifications channel returns any persisted notifications when it receives an empty message on the channel

checkDownloadNotifications

public void checkDownloadNotifications()

Retrieves download notifications

checkAllActivities

public void checkAllActivities()

Retrieves all persisted activities. The activities channel returns any persisted activities when it receives an empty message on the channel

downloadById

public void downloadById(String catalogId,
                         String sourceName)
                  throws MalformedURLException

Initiate download of a product.

Parameters:

catalogId - - Catalog ID of the product to download.

sourceName - - Name of the source to download the product from.

Throws:

MalformedURLException