El contenido de la totalidad del archivo de clase del nodo Filter utiliza el siguiente código C#:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using IBM.Broker.Plugin;
namespace SampleDotNetProject
{
///
/// FilterNode Class
///
public class FilterNode : NBComputeNode
{
///
/// Evaluate Method
///
///
public override void Evaluate(NBMessageAssembly inputAssembly)
{
NBOutputTerminal outTerminal = OutputTerminal("Out");
NBOutputTerminal altTerminal = OutputTerminal("Alternate");
NBOutputTerminal failureTerminal = OutputTerminal("Failure");
NBMessage inputMessage = inputAssembly.Message;
NBElement root = inputMessage.RootElement;
#region UserCode
// Añadir código de usuario en esta región para filtrar el mensaje
// La siguiente expresión utiliza deliberadamente "LastChild" con preferencia a "FirstChild"
// en caso de que esté presente una declaración XML
switch (root[NBParsers.XMLNSC.ParserName].LastChild.Name)
{
case "LoyaltyProgram":
outTerminal.Propagate(inputAssembly);
break;
case "SaleEnvelope":
altTerminal.Propagate(inputAssembly);
break;
default:
failureTerminal.Propagate(inputAssembly);
break;
}
#endregion UserCode
}
}
}
La región UserCode del nodo Modify utiliza el siguiente código C#:
#region UserCode
NBElement xmlRoot = outputRoot[NBParsers.XMLNSC.ParserName];
NBElement xmlDecl = xmlRoot[NBParsers.XMLNSC.XmlDeclaration, "XmlDeclaration"];
if (xmlDecl == null)
{
// Crear una declaración XML si es necesario
NBParsers.XMLNSC.CreateXmlDeclaration(xmlRoot, "1.0", "UTF-8", "yes");
}
string notargetnamespace = "";
string namespaceStore = "http://www.example.org/store";
NBElement storeDetails = xmlRoot[notargetnamespace, "LoyaltyProgram"][namespaceStore, "StoreDetails"];
string storeName = "";
string storeStreet = "";
string storeTown = "Happyville";
switch((string)storeDetails[namespaceStore,"StoreID"]) {
case "001":
storeName = "Broker Brothers Central";
storeStreet = "Exuberant Avenue";
break;
case "002":
storeName = "Broker Brothers Mall";
storeStreet = "Enthusiastic Crescent";
break;
case "003":
storeName = "Broker Brothers District";
storeStreet = "Peaceful Road";
break;
}
storeDetails.CreateLastChild(namespaceStore, "StoreName", storeName);
storeDetails.CreateLastChild(namespaceStore, "StoreStreet", storeStreet);
storeDetails.CreateLastChild(namespaceStore, "StoreTown", storeTown);
#endregion UserCode
La región UserCode del nodo Create utiliza el siguiente código C#:
#region UserCode
outputRoot["Properties"]["MessageSet"].SetValue("DotNetLibrary");
outputRoot["Properties"]["MessageType"].SetValue("File");
outputRoot.CreateLastChildUsingNewParser(NBParsers.DFDL.ParserName);
NBElement File = outputRoot[NBParsers.DFDL.ParserName].CreateFirstChild(null, "File");
NBElement inxmlRoot = inputRoot[NBParsers.XMLNSC.ParserName];
IEnumerable<NBElement> invoices = inxmlRoot["SaleEnvelope"]["SaleList"].Children("Invoice");
foreach (NBElement invoice in invoices)
{
TransformInvoice(File, invoice);
}
// Definir alteración temporal de Entorno local para controlar dinámicamente el nodo MQOutput
NBElement outputLE = outAssembly.LocalEnvironment.RootElement;
NBElement mqLE = outputLE.CreateFirstChild(null, "Destination").CreateFirstChild(null, "MQ");
mqLE.CreateFirstChild(null, "DestinationData").CreateFirstChild(null, "queueName","DOTNET.OUT");
#endregion UserCode
El código anterior también hace referencia a un método TransformInvoice, que se muestra a continuación. Si va a pegar este método en la clase C# que el nodo .NETCompute utiliza, asegúrese de colocarlo fuera del método Evaluate (por ejemplo, justo antes del método CopyMessageHeaders).
private static void TransformInvoice(NBElement outputFileElement, NBElement inputInvoiceElement)
{
// Este método crea una estructura basada en el elemento Invoice en el mensaje de entrada
IEnumerable<NBElement> items = inputInvoiceElement.Children("Item");
foreach (NBElement item in items)
{
NBElement record = outputFileElement.CreateLastChild(null, "Record");
string notargetnamespace = "";
record.CreateLastChild(notargetnamespace, "Code1", (string)item["Code", 0]);
record.CreateLastChild(notargetnamespace, "Code2", (string)item["Code", 1]);
record.CreateLastChild(notargetnamespace, "Code3", (string)item["Code", 2]);
record.CreateLastChild(notargetnamespace, "Description", (string)item["Description"]);
record.CreateLastChild(notargetnamespace, "Category", (string)item["Category"]);
record.CreateLastChild(notargetnamespace, "Price", (decimal)item["Price"]);
record.CreateLastChild(notargetnamespace, "Quantity", (Int32)item["Quantity"]);
}
}