blob: 7824ecc9a41448a93a9808e7cf6681785bfb59e2 [file] [log] [blame]
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF 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 org.apache.qpid.management.domain.model;
import java.nio.ByteBuffer;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import org.apache.qpid.transport.codec.BBDecoder;
import org.apache.qpid.transport.codec.Encoder;
/**
* Qpid method definition.
* An entity describing an invocation that can be made on a managed object instance.
*
* @author Andrea Gazzarini
*/
public class QpidMethod extends QpidFeature
{
/** Argument list */
List<QpidArgument> arguments = new LinkedList<QpidArgument>();
/**
* Builds a new qpid method definition with the given name and description.
*
* @param name the method name.
* @param description the method description.
*/
QpidMethod(String name, String description)
{
this._name = name;
this._description = description;
}
/**
* Adds an argument to this method.
*
* @param argument the new argument to be added.
*/
void addArgument(QpidArgument argument)
{
arguments.add(argument);
}
/**
* Returns a string representation of this method.
* The result format is <method name>(argType1 argName1 (Direction), argType2 argName2 (Direction), etc...)
*
* @return a string representation of this method.
*/
@Override
public String toString ()
{
StringBuilder builder = new StringBuilder()
.append(_name)
.append('(');
for (QpidArgument argument : arguments)
{
builder.append(argument).append(',');
}
builder.append(')');
return builder.toString();
}
/**
* Encodes the given parameter values according to this method arguments definitions.
* Note that only Input/Output and Input parameters are encoded.
*
* @param parameters the parameters values.
* @param encoder the encoder used for encoding.
*/
public void encodeParameters (Object[] parameters, Encoder encoder)
{
int index = 0;
for (QpidArgument argument : arguments)
{
if (argument.getDirection() != Direction.O)
{
argument.encode(parameters[index++],encoder);
}
}
}
/**
* Decodes the given input raw according to this method arguments definitions.
* Note that only Input/Output and Output parameters are encoded.
*
* @param parameters the parameters values.
* @param encoder the encoder used for encoding.
*/
public Map<String, Object> decodeParameters (byte [] values)
{
BBDecoder decoder = new BBDecoder();
decoder.init(ByteBuffer.wrap(values));
Map<String, Object> result = new HashMap<String, Object>();
for (QpidArgument argument : arguments)
{
if (argument.getDirection() != Direction.I)
{
result.put(argument.getName(),argument.decode(decoder));
}
}
return result;
}
/**
* Validates the given array of parameters against the constraint defined on this method's arguments.
*
* @param parameters the parameters (values) to be validated.
* @throws ValidationException when one of the supplied values is violating some constraint.
*/
public void validate (Object[] parameters) throws ValidationException
{
int index = 0;
for (QpidArgument argument : arguments)
{
if (argument.getDirection() != Direction.O)
{
argument.validate(parameters[index++]);
}
}
}
}