cdac.medinfo.sdk.dcm30_04.services.cmove.scp

Class CMoveSCP

java.lang.Object

cdac.medinfo.sdk.dcm30_04.services.scp.commons.SCP

cdac.medinfo.sdk.dcm30_04.services.cmove.scp.CMoveSCP

All Implemented Interfaces:

IAsyncReceiver, IProcessHandler

public class CMoveSCP
extends SCP
implements IAsyncReceiver

The C-MOVE service is invoked by a DIMSE-service-user to move the information for one or more Composite SOP Instances from a peer DIMSE-service-user, to a third party DIMSE service-user, based upon the Attributes supplied by the invoking DIMSE-service-user. C-MOVE operation supports C-STORE sub-operations being performed with an Application Entity on a separate Association. The SCU supplies Unique Key values to identify an entity at the level of the retrieval. The SCP of the C-MOVE initiates C-STORE sub-operations for the corresponding storage SOP Instances identified by Unique Key values.

Field Summary

Fields inherited from class cdac.medinfo.sdk.dcm30_04.services.scp.commons.SCP

objClientSession

Method Summary

Methods

Modifier and Type	Method and Description
void	addAETitleInfo(java.lang.String strAETitle, java.lang.String strIP, int iPort) This function will add the AE Title info for third party.
void	addAETitleInfo(java.lang.String strAETitle, java.lang.String strIP, int iPort, java.lang.Object objTlsClientConfig) This function will add the AE Title info for third party.
void	close() Closes all the currently executing sessions gracefully.
static CMoveSCP	createInstance() This method returns new object of C-Move SCP.
static CMoveSCP	createInstance(ClientSession objClientSession) This method returns new object of C-Move SCP.
IDataSource	getDataSource() retrieve the data source from which data set has to be searched based upon the Attributes supplied in C-Move request.
int	getNoOfRemainingResponses() Returns count of number of remaining responses.
void	onAssociateReceive(ClientSession objClientSession) This method notifies when Association Request, Associate Release Request or Abort is received from one of the SCUs.
void	onClose(ClientSession objClientSession) Closes client Session.
void	onConnect(ClientSession objClientSession) This method notifies when a new client connection is requested.
void	onResponseReceive(DicomMessage response) This method is call backed when Response is received.
void	onServiceRequest(ClientSession objClientSession) This method notifies when a service related request is received.
CMoveRSP	processRequest(DicomMessage objDicomMessage) This function process the C-Move Request.
void	setDataSource(IDataSource objIDataSource) Sets the data source from which data set has to be searched based upon the Attributes supplied in C-Move request.
void	start(java.lang.String strAETitle, int port) This method will Start the C-Move Server on the local host at the port specified.
void	start(java.lang.String strAETitle, java.lang.String strIP, int port) This method will Start the C-Move Server at the IP and Port specified.
void	stopListening() Stops accepting new connection's from SCU's and continue to process already connected clients.

Methods inherited from class cdac.medinfo.sdk.dcm30_04.services.scp.commons.SCP

onException

Methods inherited from class java.lang.Object

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

Method Detail

addAETitleInfo

public void addAETitleInfo(java.lang.String strAETitle,
                  java.lang.String strIP,
                  int iPort)

This function will add the AE Title info for third party.

Parameters:

strAETitle - Name of AE Title.

strIP - IP where Server is running.

iPort - Port on which server is running.

addAETitleInfo

public void addAETitleInfo(java.lang.String strAETitle,
                  java.lang.String strIP,
                  int iPort,
                  java.lang.Object objTlsClientConfig)

This function will add the AE Title info for third party.

Parameters:

strAETitle - Name of AE Title.

strIP - IP where Server is running.

iPort - Port on which server is running.

objTlsServerConfig - Object of TLSServerConfig

createInstance

public static CMoveSCP createInstance(ClientSession objClientSession)

This method returns new object of C-Move SCP.

Parameters:

objClientSession - object of Client session.

Returns:

CMoveSCP - object of CMove SCP.

createInstance

public static CMoveSCP createInstance()

This method returns new object of C-Move SCP.

Returns:

CMoveSCP - object of CMove SCP.

start

public void start(java.lang.String strAETitle,
         java.lang.String strIP,
         int port)
           throws java.io.IOException

This method will Start the C-Move Server at the IP and Port specified. This method is to start stand alone C-Move SCP.

Parameters:

strAETitle - calling AE title for this service provider.

strIP - IP at which C-Move Server has to be started.

port - at which C-Move Server has to be started.

Throws:

java.io.IOException - throws IOException if IO operation fails.

start

public void start(java.lang.String strAETitle,
         int port)
           throws java.io.IOException

This method will Start the C-Move Server on the local host at the port specified. This method is to start stand alone C-Move SCP.

Parameters:

strAETitle - calling AE title for this service provider.

port - at which C-Move Server has to be started at local host.

Throws:

java.io.IOException - throws IOException if IO operation fails.

getDataSource

public IDataSource getDataSource()

retrieve the data source from which data set has to be searched based upon the Attributes supplied in C-Move request.

Returns:

the objIDataStore - the data sourse from which data set has to be searched based upon the Attributes supplied in C-Move request.

setDataSource

public void setDataSource(IDataSource objIDataSource)

Sets the data source from which data set has to be searched based upon the Attributes supplied in C-Move request.

Parameters:

objIDataSource - - the data source from which data set has to be searched based upon the Attributes supplied in C-Move request.

processRequest

public CMoveRSP processRequest(DicomMessage objDicomMessage)

This function process the C-Move Request. It will search the matching dataset according to the attributes given in the Request. Then Performs C-Store SCU operation with the Application Entity mentioned in C-Move Request and sends Pending response to C-Move SCU. When all the C-Store operation are performed Final response in send to the C-Move SCP. Final response can be success, failure or Warning. If the final response is Warning or failure then failed SOP instance UID is also send in C-Move RSP.

Specified by:

processRequest in class SCP

Parameters:

objDicomMessage - Dicom Message which is to be processed.

Returns:

CMoveRSP - The C-Move response generated after processing the request.

Throws:

java.lang.Exception - .

onConnect

public void onConnect(ClientSession objClientSession)

This method notifies when a new client connection is requested. A decision is to be made whether to accept or reject the connection.

Specified by:

onConnect in interface IProcessHandler

Parameters:

objClientSession - object of Client Session.

onAssociateReceive

public void onAssociateReceive(ClientSession objClientSession)

This method notifies when Association Request, Associate Release Request or Abort is received from one of the SCUs. If Association Request is received, Create Association Negotiator which negotiates the request with the existing default association and creates an AgreedAssociation which contains the negotiated association values. AssociationNegotiator returns the Association Response as AssociateAC when request is accepted or returns AssociateRJ is none of the values in Association Request are acceptable. If Associate Release Request is received, Create a Associate Release Response and send the response to the SCU using the respective ClientSession. If Abort is received, An Abort response must be generated and sent using ClientSession

Specified by:

onAssociateReceive in interface IProcessHandler

Parameters:

objClientSession - object of client session.

See Also:

com.cdac.dcmlibs.services.scp.commons.ProcessHandler#processAssociation(com.cdac.dcmlibs.services.scp.commons.ClientSession, com.cdac.dcmlibs.services.dicomnetcommons.EnumPDUType)

onServiceRequest

public void onServiceRequest(ClientSession objClientSession)
                      throws java.io.IOException

This method notifies when a service related request is received. For Example, If C-Move-RQ is received, Create CMoveSCP using the ClientSession. Process the request which will search for the matches and sends the matching data set. Perform C-Store Operation with the Application entity specified in the request. Sends Pending and final Response to the C-Move SCP using the ClientSession.

Specified by:

onServiceRequest in interface IProcessHandler

Parameters:

objClientSession - object of client session.

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

onResponseReceive

public void onResponseReceive(DicomMessage response)
                       throws java.io.IOException

This method is call backed when Response is received.

Specified by:

onResponseReceive in interface IAsyncReceiver

Parameters:

response - Response received.

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

getNoOfRemainingResponses

public int getNoOfRemainingResponses()

Description copied from interface: IAsyncReceiver

Returns count of number of remaining responses.

Specified by:

getNoOfRemainingResponses in interface IAsyncReceiver

Returns:

int

onClose

public void onClose(ClientSession objClientSession)

Closes client Session.

Specified by:

onClose in interface IProcessHandler

Parameters:

objClientSession - Object of Client Session.

stopListening

public void stopListening()

Stops accepting new connection's from SCU's and continue to process already connected clients.

close

public void close()

Closes all the currently executing sessions gracefully.