| | |
|---|
| | | */
|
|---|
| | | public class MessagePipeLine implements IMessagePipeLine, IHandleMessage {
|
|---|
| | |
|
|---|
| | | public final static List<IHandleFlow> queue = new ArrayList<>();
|
|---|
| | | public final List<IHandleFlow> queue = new ArrayList<>();
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void add(IHandleFlow flow) {
|
|---|
| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void read(byte[] data) throws Exception {
|
|---|
| | | public void read(byte[] data,String ipaddress) throws Exception {
|
|---|
| | | Object out = data;
|
|---|
| | | for (int i = 0; i < queue.size(); i++) {
|
|---|
| | | IHandleFlow flow = queue.get(i);
|
|---|
| | | Object read = flow.read(out);
|
|---|
| | | Object read = flow.read(out,ipaddress);
|
|---|
| | | try {
|
|---|
| | | out = Objects.requireNonNull(read);
|
|---|
| | | } catch (Exception ignored) {
|
|---|
