File tree Expand file tree Collapse file tree 2 files changed +9
-1
lines changed
main/java/com/arangodb/internal/velocystream Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Original file line number Diff line number Diff line change 49
49
public abstract class Connection {
50
50
51
51
private static final Logger LOGGER = LoggerFactory .getLogger (Connection .class );
52
+ private static final byte [] ACCEPT_HEADER = ByteBuffer .wrap ("VST/1.0\r \n \r \n " .getBytes ())
53
+ .order (ByteOrder .LITTLE_ENDIAN ).array ();
52
54
53
55
private final String host ;
54
56
private final Integer port ;
@@ -109,6 +111,7 @@ public synchronized void open() throws IOException {
109
111
}
110
112
((SSLSocket ) socket ).startHandshake ();
111
113
}
114
+ sendAcceptHeader ();
112
115
}
113
116
114
117
public synchronized void close () {
@@ -124,6 +127,11 @@ public synchronized void close() {
124
127
}
125
128
}
126
129
130
+ private void sendAcceptHeader () throws IOException {
131
+ outputStream .write (ACCEPT_HEADER );
132
+ outputStream .flush ();
133
+ }
134
+
127
135
protected synchronized void writeIntern (final Message message , final Collection <Chunk > chunks ) {
128
136
for (final Chunk chunk : chunks ) {
129
137
try {
Original file line number Diff line number Diff line change 8
8
</encoder >
9
9
</appender >
10
10
11
- <root level =" info " >
11
+ <root level =" debug " >
12
12
<appender-ref ref =" STDOUT" />
13
13
</root >
14
14
</configuration >
You can’t perform that action at this time.
0 commit comments