Leider ist es nicht möglich, eine Queue als Parameter anzugeben. Sie können nur den Namen einer Queue als Zeichenkette eingeben lassen, und die Queue dann über diesen Namen ermitteln. Nutzen Sie dazu die Port-Klassen wie im Beispiel.
import com.sqlgmbh.tc.message.MessagePort;
import com.sqlgmbh.tc.processing.QueueManagerPort;
...
QueueManagerPort qPort = CommunicationBus.getLocal().getPort( QueueManagerPort.class );
MessagePort msgPort = CommunicationBus.getLocal().getPort( MessagePort.class );
ContainerList<QueueConfig> configurations = qPort.getQueueConfigs();
QueueConfig qc;
for( QueueConfig config : configurations )
{
if( config.name.equals( "queuename" )
{
qc = config;
break;
}
}
try( CloseableIterator<QueueEntryComposite> it = msgPort.browse( qc.getID(), 100 /* limit */, true /* ascending */ ) )
{
QueueEntryComposite entry = it.next();
}
|
Ihr TRANSCONNECT-Team
