Scopri come trovare il graphic designer perfetto per il tuo progetto con la nostra guida completa. Analizziamo le competenze necessarie, i canali per la ricerca e i criteri da considerare per scegliere il professionista ideale. Non lasciare nulla al caso e valorizza la tua idea creativa!
Trova professionisti vicino a te
Trova professionisti
/*
* Copyright (c) 2018, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
*
* WSO2 Inc. 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.ballerina.messaging.broker.amqp.codec.frames;
import io.ballerina.messaging.broker.amqp.codec.handlers.AmqpConnectionHandler;
import io.ballerina.messaging.broker.common.data.types.LongString;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
/**
* AMQP frame for exchange.declare-ok
* Parameter Summary:
* 1. exchange (LongString) - Name of the exchange
*/
public class ExchangeDeclareOk extends MethodFrame {
private static final short CLASS_ID = 40;
private static final short METHOD_ID = 11;
private final LongString exchange;
public ExchangeDeclareOk(int channel, LongString exchange) {
super(channel, CLASS_ID, METHOD_ID);
this.exchange = exchange;
}
@Override
protected long getMethodBodySize() {
return exchange.getSize();
}
@Override
protected void writeMethod(ByteBuf buf) {
exchange.write(buf);
}
@Override
public void handle(ChannelHandlerContext ctx, AmqpConnectionHandler connectionHandler) {
// Server does not handle this frame
}
public static AmqMethodBodyFactory getFactory() {
return (buf, channel, size) -> {
LongString exchange = LongString.parse(buf);
return new ExchangeDeclareOk(channel, exchange);
};
}
}