{
try
{
Response<Long> response = broker.getMaster().commitSingleResourceTransaction(
broker.getSlaveContext(), ((TxManager) txManager).getEventIdentifier(),
<BUG>dataSource.getName(), new TransactionStream(

dataSource.getCommittedTransaction( identifier ) ) );
</BUG>
return receiver.receive( response );

{
public static class SlaveTxIdGeneratorFactory implements TxIdGeneratorFactory
{
private final Broker broker;
private final ResponseReceiver receiver;
public SlaveTxIdGeneratorFactory( Broker broker, ResponseReceiver receiver )
{
this.broker = broker;
this.receiver = receiver;
