Package com.levigo.jadice.web.conn.server.messaging

Class ExportOperationMessageListener

java.lang.Object

com.levigo.jadice.web.conn.server.messaging.ExportOperationMessageListener

All Implemented Interfaces:

MessageListener<ExportOperationDTO>

@Component
public class ExportOperationMessageListener
extends Object
implements MessageListener<ExportOperationDTO>

Constructor Summary

Constructors

Constructor	Description
ExportOperationMessageListener()

Method Summary

Modifier and Type	Method	Description
CancelHandler	consume(ExportOperationDTO exportOperationDTO, IncomingMessageContext incomingMessageContext)
protected Exporter	createDefaultExporter(ExportType type)
void	doExport(ExportOperationDTO dto, IncomingMessageContext ctx)
void	setExecutorService(ExecutorService executorService)
void	setRepository(ExportRepository repository)
void	setSnapshotConverter(DocumentSnapshotConverter snapshotConverter)

Methods inherited from class java.lang.Object

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

Constructor Details

ExportOperationMessageListener

public ExportOperationMessageListener()

Method Details

setExecutorService

@Autowired(required=false)
public void setExecutorService(ExecutorService executorService)

setRepository

@Autowired(required=false)
public void setRepository(ExportRepository repository)

setSnapshotConverter

@Autowired(required=false)
public void setSnapshotConverter(DocumentSnapshotConverter snapshotConverter)

consume

public CancelHandler consume(ExportOperationDTO exportOperationDTO,
 IncomingMessageContext incomingMessageContext)
                      throws Exception

Specified by:

consume in interface MessageListener<ExportOperationDTO>

Throws:

Exception

doExport

public void doExport(ExportOperationDTO dto,
 IncomingMessageContext ctx)

createDefaultExporter

protected Exporter createDefaultExporter(ExportType type)