BEAST
eu.baltrad.beast.exchange.ExchangeManager Class Reference
Inheritance diagram for eu.baltrad.beast.exchange.ExchangeManager:
eu.baltrad.beast.exchange.IExchangeManager

Public Member Functions

 ExchangeManager ()
 Default constructor.
 
void setAuthorizationManager (IAuthorizationManager authorizationManager)
 
void setAuthorizationRequestManager (IAuthorizationRequestManager authorizationRequestManager)
 
void setConnector (ExchangeConnector connector)
 
ExchangeResponse send (SendFileRequest request)
 
ExchangeResponse send (SendFileRequest request, SendFileRequestCallback callback)
 
void sendAsync (SendFileRequest request, SendFileRequestCallback callback)
 Publishes a send file request asynchronously.
 
ExchangeMessage parse (InputStream stream)
 
ExchangeMessage receive (ExchangeMessage message)
 
ExchangeMessage receive (InputStream stream)
 
AuthorizationRequest requestAuthorization (String remoteAddress, String message)
 
void approve (AuthorizationRequest request)
 
void deny (AuthorizationRequest request)
 
void delete (AuthorizationRequest request)
 
ISecurityManager getSecurityManager ()
 
void setSecurityManager (ISecurityManager securityManager)
 
String getExchangeUrlPart ()
 
void setExchangeUrlPart (String exchangeUrlPart)
 
Map< String, IPooledFileRequestPublishergetPooledPublishers ()
 
void setPooledPublishers (Map< String, IPooledFileRequestPublisher > pooledPublishers)
 
int getQueueSize ()
 
void setQueueSize (int queueSize)
 
int getCorePoolSize ()
 
void setCorePoolSize (int corePoolSize)
 
int getMaxPoolSize ()
 
void setMaxPoolSize (int maxPoolSize)
 

Protected Member Functions

SendFileRequest createNewRequest (SendFileRequest request, String address)
 
IPooledFileRequestPublisher createPooledFileRequestPublisher ()
 Creates a pooled file request publisher.
 

Detailed Description

Author
anders

Constructor & Destructor Documentation

◆ ExchangeManager()

eu.baltrad.beast.exchange.ExchangeManager.ExchangeManager ( )
inline

Default constructor.

Member Function Documentation

◆ approve()

void eu.baltrad.beast.exchange.ExchangeManager.approve ( AuthorizationRequest request)
inline
See also
IExchangeManager.approve(AuthorizationRequest)
Parameters
requestthe authorization request to approve

Implements eu.baltrad.beast.exchange.IExchangeManager.

◆ createPooledFileRequestPublisher()

IPooledFileRequestPublisher eu.baltrad.beast.exchange.ExchangeManager.createPooledFileRequestPublisher ( )
inlineprotected

Creates a pooled file request publisher.

Returns
the publisher

◆ delete()

void eu.baltrad.beast.exchange.ExchangeManager.delete ( AuthorizationRequest request)
inline
Parameters
requestthe request to remove

Implements eu.baltrad.beast.exchange.IExchangeManager.

◆ deny()

void eu.baltrad.beast.exchange.ExchangeManager.deny ( AuthorizationRequest request)
inline
See also
IExchangeManager.deny(AuthorizationRequest)
Parameters
requestthe authorization request to deny

Implements eu.baltrad.beast.exchange.IExchangeManager.

◆ getCorePoolSize()

int eu.baltrad.beast.exchange.ExchangeManager.getCorePoolSize ( )
inline
Returns
the core thread executor pool size

◆ getExchangeUrlPart()

String eu.baltrad.beast.exchange.ExchangeManager.getExchangeUrlPart ( )
inline
Returns
the url part that should be placed after the destination url, as an example "/BaltradDex/exchangeManager.htm", if the destination URL is http://localhost:8080, then with the exchange url part, the full URL will be http://localhost:8080/BaltradDex/exchangeManager.htm

◆ getMaxPoolSize()

int eu.baltrad.beast.exchange.ExchangeManager.getMaxPoolSize ( )
inline
Returns
the max thread executor pool size

◆ getPooledPublishers()

Map< String, IPooledFileRequestPublisher > eu.baltrad.beast.exchange.ExchangeManager.getPooledPublishers ( )
inline
Returns
the pooled publisher map

◆ getQueueSize()

int eu.baltrad.beast.exchange.ExchangeManager.getQueueSize ( )
inline
Returns
the max number of entries in the queue

◆ getSecurityManager()

ISecurityManager eu.baltrad.beast.exchange.ExchangeManager.getSecurityManager ( )
inline
Returns
the security manager

◆ parse()

ExchangeMessage eu.baltrad.beast.exchange.ExchangeManager.parse ( InputStream stream)
inline

◆ receive() [1/2]

ExchangeMessage eu.baltrad.beast.exchange.ExchangeManager.receive ( ExchangeMessage message)
inline
See also
IExchangeManager.receive(ExchangeMessage)

Implements eu.baltrad.beast.exchange.IExchangeManager.

◆ receive() [2/2]

ExchangeMessage eu.baltrad.beast.exchange.ExchangeManager.receive ( InputStream stream)
inline
See also
IExchangeManager.receive(InputStream)

Implements eu.baltrad.beast.exchange.IExchangeManager.

◆ requestAuthorization()

AuthorizationRequest eu.baltrad.beast.exchange.ExchangeManager.requestAuthorization ( String remoteAddress,
String message )
inline

◆ send() [1/2]

ExchangeResponse eu.baltrad.beast.exchange.ExchangeManager.send ( SendFileRequest request)
inline

◆ send() [2/2]

◆ sendAsync()

void eu.baltrad.beast.exchange.ExchangeManager.sendAsync ( SendFileRequest request,
SendFileRequestCallback callback )
inline

Publishes a send file request asynchronously.

Parameters
requestthe request
callbackthe callback

Implements eu.baltrad.beast.exchange.IExchangeManager.

◆ setAuthorizationManager()

void eu.baltrad.beast.exchange.ExchangeManager.setAuthorizationManager ( IAuthorizationManager authorizationManager)
inline
Parameters
authorizationManagerthe authorization manager

◆ setAuthorizationRequestManager()

void eu.baltrad.beast.exchange.ExchangeManager.setAuthorizationRequestManager ( IAuthorizationRequestManager authorizationRequestManager)
inline
Parameters
authorizationRequestManagerthe authorization request manager

◆ setConnector()

void eu.baltrad.beast.exchange.ExchangeManager.setConnector ( ExchangeConnector connector)
inline
Parameters
connectorthe connector

◆ setCorePoolSize()

void eu.baltrad.beast.exchange.ExchangeManager.setCorePoolSize ( int corePoolSize)
inline
Parameters
corePoolSizethe min thread executor pool size

◆ setExchangeUrlPart()

void eu.baltrad.beast.exchange.ExchangeManager.setExchangeUrlPart ( String exchangeUrlPart)
inline
Parameters
exchangeUrlPartthe exchange url part

◆ setMaxPoolSize()

void eu.baltrad.beast.exchange.ExchangeManager.setMaxPoolSize ( int maxPoolSize)
inline
Parameters
maxPoolSizethe max thread executor pool size

◆ setPooledPublishers()

void eu.baltrad.beast.exchange.ExchangeManager.setPooledPublishers ( Map< String, IPooledFileRequestPublisher > pooledPublishers)
inline
Parameters
pooledPublishersthe pooled publisher map

◆ setQueueSize()

void eu.baltrad.beast.exchange.ExchangeManager.setQueueSize ( int queueSize)
inline
Parameters
queueSizethe max number of entries in the queue

◆ setSecurityManager()

void eu.baltrad.beast.exchange.ExchangeManager.setSecurityManager ( ISecurityManager securityManager)
inline
Parameters
securityManager

The documentation for this class was generated from the following file: