hunt.stomp.simp.stomp.StompReactorNettyCodec source code

1 /*
2  * Copyright 2002-2016 the original author or authors.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 module hunt.stomp.simp.stomp.StompReactorNettyCodec;
17 
18 // import java.nio.ByteBuffer;
19 // import java.util.List;
20 
21 // import hunt.stomp.Message;
22 // import hunt.stomp.tcp.reactor.AbstractNioBufferReactorNettyCodec;
23 
24 // /**
25 //  * Simple delegation to StompDecoder and StompEncoder.
26 //  *
27 //  * @author Rossen Stoyanchev
28 //  * @since 5.0
29 //  */
30 // public class StompReactorNettyCodec : AbstractNioBufferReactorNettyCodec!(byte[]) {
31 
32 // 	private final StompDecoder decoder;
33 
34 // 	private final StompEncoder encoder;
35 
36 
37 // 	public StompReactorNettyCodec() {
38 // 		this(new StompDecoder());
39 // 	}
40 
41 // 	public StompReactorNettyCodec(StompDecoder decoder) {
42 // 		this(decoder, new StompEncoder());
43 // 	}
44 
45 // 	public StompReactorNettyCodec(StompDecoder decoder, StompEncoder encoder) {
46 // 		this.decoder = decoder;
47 // 		this.encoder = encoder;
48 // 	}
49 
50 
51 // 	override
52 // 	protected List!(Message!(byte[])) decodeInternal(ByteBuffer nioBuffer) {
53 // 		return this.decoder.decode(nioBuffer);
54 // 	}
55 
56 // 	protected ByteBuffer encodeInternal(Message!(byte[]) message) {
57 // 		return ByteBuffer.wrap(this.encoder.encode(message));
58 // 	}
59 
60 // }