Skip to content

Commit 639ebce

Browse files
If applied, this commit will ajust multi layer balancer.
1 parent 37bc323 commit 639ebce

File tree

3 files changed

+9
-8
lines changed

3 files changed

+9
-8
lines changed

src/main/java/dlt/load/balancer/model/AbstractProcessSendDeviceState.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,8 @@ public void onEnter() {
3535

3636
@Override
3737
protected void handleValidTransaction(Transaction transaction) {
38-
logger.info("LB_*DEVICE*RESPONSE recebido com target correto. Iniciando envio de LB_REQUEST.");
38+
logger.info("LB_*RESPONSE recebido com target correto. Iniciando envio de LB_*REQUEST.");
39+
3940
Transaction transactionRequest;
4041
String sender = transaction.getSource();
4142
try {
@@ -49,7 +50,7 @@ protected void handleValidTransaction(Transaction transaction) {
4950
this.transiteToNextState();
5051
} catch (IOException ex) {
5152
logger.log(Level.SEVERE, null, ex);
52-
} catch (NoSuchElementException ex){
53+
} catch (NoSuchElementException ex) {
5354
logger.warning("AbstractProcessSendDeviceState - Device list is empty.");
5455
}
5556
this.updateQtyResendTransaction();

src/main/java/dlt/load/balancer/model/ProcessMultiLayerSendDeviceState.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package dlt.load.balancer.model;
22

33
import dlt.client.tangle.hornet.enums.TransactionType;
4-
import dlt.client.tangle.hornet.model.transactions.LBMultiDeviceResponse;
4+
import dlt.client.tangle.hornet.model.transactions.LBMultiDevice;
55
import dlt.client.tangle.hornet.model.transactions.Transaction;
66
import java.util.logging.Level;
77
import java.util.logging.Logger;
@@ -19,18 +19,18 @@ public ProcessMultiLayerSendDeviceState(Balancer balancer, Transaction transacti
1919

2020
@Override
2121
protected Transaction buildTransaction(String deviceJson, String sender) {
22-
return new LBMultiDeviceResponse(source, group, deviceJson, sender);
22+
return new LBMultiDevice(source, group, deviceJson, sender);
2323
}
2424

2525
@Override
2626
protected boolean isValidTransaction(Transaction transaction) {
2727
return transaction.isMultiLayerTransaction()
28-
&& transaction.is(TransactionType.LB_MULTI_DEVICE_RESPONSE);
28+
&& transaction.is(TransactionType.LB_MULTI_RESPONSE);
2929
}
3030

3131
@Override
3232
protected void handleInvalidTransaction(Transaction trans) {
33-
logger.log(Level.INFO, "Acceptable trans: LB_MULTI_DEVICE_RESPONSE.");
33+
logger.log(Level.INFO, "Acceptable trans: LB_MULTI_RESPONSE.");
3434
}
3535

3636
}

src/main/java/dlt/load/balancer/model/WaitingLBReplyState.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,12 +28,12 @@ public void onEnter() {
2828
protected boolean isValidTransaction(Transaction transaction) {
2929
return transaction.is(TransactionType.LB_ENTRY_REPLY)
3030
|| (transaction.isMultiLayerTransaction()
31-
&& transaction.is(TransactionType.LB_MULTI_DEVICE_RESPONSE));
31+
&& transaction.is(TransactionType.LB_MULTI_RESPONSE));
3232
}
3333

3434
@Override
3535
protected void handleInvalidTransaction(Transaction trans) {
36-
logger.log(Level.INFO, "Acceptable trans: LB_ENTRY_REPLY or LB_MULTI_DEVICE_RESPONSE.");
36+
logger.log(Level.INFO, "Acceptable trans: LB_ENTRY_REPLY or LB_MULTI_RESPONSE.");
3737
}
3838

3939
@Override

0 commit comments

Comments
 (0)