Skip to content

Commit 4bf4943

Browse files
committed
Move ConnectionSetup to scalecube-services-api module
1 parent 6735c79 commit 4bf4943

File tree

7 files changed

+9
-3
lines changed

7 files changed

+9
-3
lines changed
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.scalecube.services.transport.rsocket;
1+
package io.scalecube.services.auth;
22

33
import io.scalecube.utils.MaskUtil;
44
import java.io.Externalizable;
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.scalecube.services.transport.rsocket;
1+
package io.scalecube.services.auth;
22

33
import java.io.IOException;
44
import java.io.InputStream;
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.scalecube.services.transport.rsocket;
1+
package io.scalecube.services.auth;
22

33
import java.io.IOException;
44
import java.io.InputStream;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,8 @@
1010
import io.rsocket.util.ByteBufPayload;
1111
import io.scalecube.net.Address;
1212
import io.scalecube.services.ServiceReference;
13+
import io.scalecube.services.auth.ConnectionSetup;
14+
import io.scalecube.services.auth.ConnectionSetupCodec;
1315
import io.scalecube.services.auth.CredentialsSupplier;
1416
import io.scalecube.services.exceptions.MessageCodecException;
1517
import io.scalecube.services.exceptions.ServiceException;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServerTransport.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import io.rsocket.transport.netty.server.CloseableChannel;
66
import io.scalecube.net.Address;
77
import io.scalecube.services.auth.Authenticator;
8+
import io.scalecube.services.auth.ConnectionSetupCodec;
89
import io.scalecube.services.methods.ServiceMethodRegistry;
910
import io.scalecube.services.transport.api.DataCodec;
1011
import io.scalecube.services.transport.api.HeadersCodec;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServiceAcceptor.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,8 @@
99
import io.rsocket.util.ByteBufPayload;
1010
import io.scalecube.services.api.ServiceMessage;
1111
import io.scalecube.services.auth.Authenticator;
12+
import io.scalecube.services.auth.ConnectionSetup;
13+
import io.scalecube.services.auth.ConnectionSetupCodec;
1214
import io.scalecube.services.exceptions.BadRequestException;
1315
import io.scalecube.services.exceptions.MessageCodecException;
1416
import io.scalecube.services.exceptions.ServiceException;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServiceTransport.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
import io.netty.util.concurrent.DefaultThreadFactory;
88
import io.netty.util.concurrent.Future;
99
import io.scalecube.services.auth.Authenticator;
10+
import io.scalecube.services.auth.ConnectionSetupCodec;
1011
import io.scalecube.services.auth.CredentialsSupplier;
1112
import io.scalecube.services.methods.ServiceMethodRegistry;
1213
import io.scalecube.services.transport.api.ClientTransport;

0 commit comments

Comments
 (0)