import com.hazelcast.queue.QueueDataSerializerHook;
import com.hazelcast.queue.QueueOperation;
import com.hazelcast.spi.WaitNotifyKey;
<BUG>import com.hazelcast.spi.WaitSupport;
public class TxnReserveOfferOperation extends QueueOperation implements WaitSupport {
public TxnReserveOfferOperation() {</BUG>
}
<BUG>public TxnReserveOfferOperation(String name, long timeoutMillis) {

super(name, timeoutMillis);
}</BUG>
public void run() throws Exception {

import com.hazelcast.queue.QueueDataSerializerHook;
import com.hazelcast.queue.QueueOperation;
import com.hazelcast.spi.WaitNotifyKey;
import com.hazelcast.spi.WaitSupport;
import java.io.IOException;
public class TxnReserveOfferOperation extends QueueOperation implements WaitSupport {
int txSize;
public TxnReserveOfferOperation() {
}
public TxnReserveOfferOperation(String name, long timeoutMillis, int txSize) {
super(name, timeoutMillis);
this.txSize = txSize;
}
public void run() throws Exception {
