Skip to content

Commit

Permalink
Fix of the AmqpClientActor class formating
Browse files Browse the repository at this point in the history
  • Loading branch information
SilviaGeorgievaLyoteva committed Aug 30, 2022
1 parent 415bf35 commit 5f7541e
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,6 @@ private AmqpClientActor(final Connection connection,
public static Props props(final Connection connection, final ActorRef commandForwarderActor,
final ActorRef connectionActor, final Config configOverwrites, final ActorSystem actorSystem,
final DittoHeaders dittoHeaders) {

return Props.create(AmqpClientActor.class, validateConnection(connection, actorSystem),
commandForwarderActor, connectionActor, configOverwrites, dittoHeaders);
}
Expand All @@ -199,14 +198,13 @@ public static Props props(final Connection connection, final ActorRef commandFor
static Props propsForTest(final Connection connection, @Nullable final ActorRef commandForwarderActor,
final ActorRef connectionActor, final JmsConnectionFactory jmsConnectionFactory,
final ActorSystem actorSystem) {

return Props.create(AmqpClientActor.class, validateConnection(connection, actorSystem),
jmsConnectionFactory, commandForwarderActor, connectionActor, DittoHeaders.empty());
}

private static Connection validateConnection(final Connection connection, final ActorSystem actorSystem) {
try {
final String connectionUri = ConnectionBasedJmsConnectionFactory.buildAmqpConnectionUri(connection,
final String connectionUri = ConnectionBasedJmsConnectionFactory.buildAmqpConnectionUri(connection,
connection.getId().toString(),
// fake established tunnel state for uri validation
() -> SshTunnelState.from(connection).established(22222),
Expand Down

0 comments on commit 5f7541e

Please sign in to comment.