|
Java example source code file (SctpOutboundByteStreamHandler.java)
The SctpOutboundByteStreamHandler.java Java example source code/* * Copyright 2012 The Netty Project * * The Netty Project licenses this file to you under the Apache License, * version 2.0 (the "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. */ package io.netty.handler.codec.sctp; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.sctp.SctpMessage; import io.netty.handler.codec.MessageToMessageEncoder; import java.util.List; /** * A ChannelHandler which transform {@link ByteBuf} to {@link SctpMessage} and send it through a specific stream * with given protocol identifier. * Unordered delivery of all messages may be requested by passing unordered = true to the constructor. */ public class SctpOutboundByteStreamHandler extends MessageToMessageEncoder<ByteBuf> { private final int streamIdentifier; private final int protocolIdentifier; private final boolean unordered; /** * @param streamIdentifier stream number, this should be >=0 or <= max stream number of the association. * @param protocolIdentifier supported application protocol id. */ public SctpOutboundByteStreamHandler(int streamIdentifier, int protocolIdentifier) { this(streamIdentifier, protocolIdentifier, false); } /** * @param streamIdentifier stream number, this should be >=0 or <= max stream number of the association. * @param protocolIdentifier supported application protocol id. * @param unordered if {@literal true}, SCTP Data Chunks will be sent with the U (unordered) flag set. */ public SctpOutboundByteStreamHandler(int streamIdentifier, int protocolIdentifier, boolean unordered) { this.streamIdentifier = streamIdentifier; this.protocolIdentifier = protocolIdentifier; this.unordered = unordered; } @Override protected void encode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception { out.add(new SctpMessage(streamIdentifier, protocolIdentifier, unordered, msg.retain())); } } Other Java examples (source code examples)Here is a short list of links related to this Java SctpOutboundByteStreamHandler.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.