http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/crm/employee/Employee.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/crm/employee/Employee.java b/apps/samples/WEB-INF/src/flex/samples/crm/employee/Employee.java deleted file mode 100755 index df61b32..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/crm/employee/Employee.java +++ /dev/null @@ -1,106 +0,0 @@ -/* - * 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 flex.samples.crm.employee; - -import flex.samples.crm.company.Company; - -public class Employee -{ - private int employeeId; - - private String firstName; - - private String lastName; - - private String title; - - private String email; - - private String phone; - - private Company company; - - public String getEmail() - { - return email; - } - - public void setEmail(String email) - { - this.email = email; - } - - public int getEmployeeId() - { - return employeeId; - } - - public void setEmployeeId(int employeeId) - { - this.employeeId = employeeId; - } - - public String getFirstName() - { - return firstName; - } - - public void setFirstName(String firstName) - { - this.firstName = firstName; - } - - public String getLastName() - { - return lastName; - } - - public void setLastName(String lastName) - { - this.lastName = lastName; - } - - public String getPhone() - { - return phone; - } - - public void setPhone(String phone) - { - this.phone = phone; - } - - public String getTitle() - { - return title; - } - - public void setTitle(String title) - { - this.title = title; - } - - public Company getCompany() - { - return company; - } - - public void setCompany(Company company) - { - this.company = company; - } -}
http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/crm/employee/EmployeeDAO.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/crm/employee/EmployeeDAO.java b/apps/samples/WEB-INF/src/flex/samples/crm/employee/EmployeeDAO.java deleted file mode 100755 index c165016..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/crm/employee/EmployeeDAO.java +++ /dev/null @@ -1,300 +0,0 @@ -/* - * 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 flex.samples.crm.employee; - -import java.sql.Connection; -import java.sql.PreparedStatement; -import java.sql.Statement; -import java.sql.ResultSet; -import java.sql.SQLException; -import java.sql.Types; -import java.util.ArrayList; -import java.util.List; - -import flex.samples.ConnectionHelper; -import flex.samples.DAOException; -import flex.samples.crm.ConcurrencyException; -import flex.samples.crm.company.Company; - -public class EmployeeDAO -{ - public List getEmployees() throws DAOException - { - List list = new ArrayList(); - Connection c = null; - try - { - c = ConnectionHelper.getConnection(); - Statement s = c.createStatement(); - ResultSet rs = s.executeQuery("SELECT * FROM employee ORDER BY last_name"); - Employee employee; - while (rs.next()) - { - employee = new Employee(); - employee.setEmployeeId(rs.getInt("employee_id")); - employee.setFirstName(rs.getString("first_name")); - employee.setLastName(rs.getString("last_name")); - employee.setTitle(rs.getString("title")); - employee.setEmail(rs.getString("email")); - employee.setPhone(rs.getString("phone")); - Company company = new Company(); - company.setCompanyId(rs.getInt("company_id")); - employee.setCompany(company); - list.add(employee); - } - } - catch (SQLException e) - { - e.printStackTrace(); - throw new DAOException(e); - } - finally - { - ConnectionHelper.close(c); - } - return list; - } - - public List findEmployeesByCompany(Integer companyId) throws DAOException - { - List list = new ArrayList(); - Connection c = null; - try - { - Company company = new Company(); - company.setCompanyId(companyId.intValue()); - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("SELECT * FROM employee WHERE company_id = ? ORDER BY last_name"); - ps.setInt(1, companyId.intValue()); - ResultSet rs = ps.executeQuery(); - while (rs.next()) - { - Employee employee = new Employee(); - employee.setEmployeeId(rs.getInt("employee_id")); - employee.setFirstName(rs.getString("first_name")); - employee.setLastName(rs.getString("last_name")); - employee.setTitle(rs.getString("title")); - employee.setEmail(rs.getString("email")); - employee.setPhone(rs.getString("phone")); - employee.setCompany(company); - list.add(employee); - } - } - catch (SQLException e) - { - e.printStackTrace(); - throw new DAOException(e); - } - finally - { - ConnectionHelper.close(c); - } - return list; - } - - public List findEmployeesByName(String name) throws DAOException - { - List list = new ArrayList(); - Connection c = null; - - try - { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("SELECT * FROM employee WHERE first_name LIKE ? OR last_name LIKE ? ORDER BY last_name"); - ps.setString(1, "%" + name + "%"); - ps.setString(2, "%" + name + "%"); - ResultSet rs = ps.executeQuery(); - - Employee employee; - while (rs.next()) - { - employee = new Employee(); - employee.setEmployeeId(rs.getInt("employee_id")); - employee.setFirstName(rs.getString("first_name")); - employee.setLastName(rs.getString("last_name")); - employee.setTitle(rs.getString("title")); - employee.setEmail(rs.getString("email")); - employee.setPhone(rs.getString("phone")); - Company company = new Company(); - company.setCompanyId(rs.getInt("company_id")); - - list.add(employee); - } - } - catch (SQLException e) - { - e.printStackTrace(); - throw new DAOException(e); - } - finally - { - ConnectionHelper.close(c); - } - return list; - } - - public Employee getEmployee(int employeeId) throws DAOException - { - Employee employee = null; - Connection c = null; - - try - { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("SELECT * FROM employee WHERE employee_id= ?"); - ps.setInt(1, employeeId); - ResultSet rs = ps.executeQuery(); - - if (rs.next()) - { - employee = new Employee(); - employee.setEmployeeId(rs.getInt("employee_id")); - employee.setFirstName(rs.getString("first_name")); - employee.setLastName(rs.getString("last_name")); - employee.setTitle(rs.getString("title")); - employee.setEmail(rs.getString("email")); - employee.setPhone(rs.getString("phone")); - } - } - catch (SQLException e) - { - e.printStackTrace(); - throw new DAOException(e.getMessage()); - } - finally - { - ConnectionHelper.close(c); - } - return employee; - } - - public Employee createEmployee(Employee employee) throws DAOException - { - Connection c = null; - PreparedStatement ps = null; - try - { - c = ConnectionHelper.getConnection(); - ps = c.prepareStatement("INSERT INTO employee (first_name, last_name, title, email, phone, company_id) VALUES (?, ?, ?, ?, ?, ?)"); - ps.setString(1, employee.getFirstName()); - ps.setString(2, employee.getLastName()); - ps.setString(3, employee.getTitle()); - ps.setString(4, employee.getEmail()); - ps.setString(5, employee.getPhone()); - if (employee.getCompany() != null) - ps.setInt(6, employee.getCompany().getCompanyId()); - else - ps.setNull(6, Types.INTEGER); - ps.execute(); - ps.close(); - Statement s = c.createStatement(); - // HSQLDB Syntax to get the identity (employee_id) of inserted row - ResultSet rs = s.executeQuery("CALL IDENTITY()"); - rs.next(); - // Update the id in the returned object. This is important as this - // value must get returned to the client. - employee.setEmployeeId(rs.getInt(1)); - } - catch (SQLException e) - { - e.printStackTrace(); - throw new DAOException(e); - } - finally - { - ConnectionHelper.close(c); - } - return employee; - } - - - public void updateEmployee(Employee newVersion, Employee previousVersion, List changes) throws DAOException, ConcurrencyException - { - Connection c = null; - try - { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("UPDATE employee SET first_name=?, last_name=?, title=?, email=?, phone=?, company_id=? WHERE employee_id=? AND first_name=? AND last_name=? AND title=? AND email=? AND phone=? AND company_id=?"); - ps.setString(1, newVersion.getFirstName()); - ps.setString(2, newVersion.getLastName()); - ps.setString(3, newVersion.getTitle()); - ps.setString(4, newVersion.getEmail()); - ps.setString(5, newVersion.getPhone()); - if (newVersion.getCompany() != null) - ps.setInt(6, newVersion.getCompany().getCompanyId()); - else - ps.setNull(6,Types.INTEGER); - ps.setInt(7, newVersion.getEmployeeId()); - ps.setString(8, previousVersion.getFirstName()); - ps.setString(9, previousVersion.getLastName()); - ps.setString(10, previousVersion.getTitle()); - ps.setString(11, previousVersion.getEmail()); - ps.setString(12, previousVersion.getPhone()); - if (previousVersion.getCompany() != null) - ps.setInt(13, previousVersion.getCompany().getCompanyId()); - else - ps.setNull(13, Types.INTEGER); - if (ps.executeUpdate() == 0) - { - throw new ConcurrencyException("Item not found"); - } - } - catch (SQLException e) - { - e.printStackTrace(); - throw new DAOException(e.getMessage()); - } - finally - { - ConnectionHelper.close(c); - } - } - - public void deleteEmployee(Employee employee) throws DAOException, ConcurrencyException - { - Connection c = null; - try - { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("DELETE FROM employee WHERE employee_id=? AND first_name=? AND last_name=? AND title=? AND email=? AND phone=? AND company_id=?"); - ps.setInt(1, employee.getEmployeeId()); - ps.setString(2, employee.getFirstName()); - ps.setString(3, employee.getLastName()); - ps.setString(4, employee.getTitle()); - ps.setString(5, employee.getEmail()); - ps.setString(6, employee.getPhone()); - if (employee.getCompany() != null) - ps.setInt(7, employee.getCompany().getCompanyId()); - else - ps.setNull(7, Types.INTEGER); - if (ps.executeUpdate() == 0) - { - throw new ConcurrencyException("Item not found"); - } - } - catch (SQLException e) - { - e.printStackTrace(); - throw new DAOException(e.getMessage()); - } - finally - { - ConnectionHelper.close(c); - } - } - -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/dcd/product/Product.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/dcd/product/Product.java b/apps/samples/WEB-INF/src/flex/samples/dcd/product/Product.java deleted file mode 100755 index d46544e..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/dcd/product/Product.java +++ /dev/null @@ -1,89 +0,0 @@ -/* - * 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 flex.samples.dcd.product; -import java.io.Serializable; - -public class Product implements Serializable { - - static final long serialVersionUID = 103844514947365244L; - - private int productId; - private String name; - private String description; - private String image; - private String category; - private double price; - private int qtyInStock; - - public Product() { - - } - - public Product(int productId, String name, String description, String image, String category, double price, int qtyInStock) { - this.productId = productId; - this.name = name; - this.description = description; - this.image = image; - this.category = category; - this.price = price; - this.qtyInStock = qtyInStock; - } - - public String getCategory() { - return category; - } - public void setCategory(String category) { - this.category = category; - } - public String getDescription() { - return description; - } - public void setDescription(String description) { - this.description = description; - } - public String getImage() { - return image; - } - public void setImage(String image) { - this.image = image; - } - public String getName() { - return name; - } - public void setName(String name) { - this.name = name; - } - public double getPrice() { - return price; - } - public void setPrice(double price) { - this.price = price; - } - public int getProductId() { - return productId; - } - public void setProductId(int productId) { - this.productId = productId; - } - public int getQtyInStock() { - return qtyInStock; - } - public void setQtyInStock(int qtyInStock) { - this.qtyInStock = qtyInStock; - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/dcd/product/ProductService.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/dcd/product/ProductService.java b/apps/samples/WEB-INF/src/flex/samples/dcd/product/ProductService.java deleted file mode 100755 index dcf1ba9..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/dcd/product/ProductService.java +++ /dev/null @@ -1,197 +0,0 @@ -/* - * 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 flex.samples.dcd.product; - -import java.util.ArrayList; -import java.util.List; -import java.sql.*; -import flex.samples.ConnectionHelper; -import flex.samples.DAOException; -import java.util.Iterator; - -public class ProductService { - - public Product[] getProducts() throws DAOException { - - List list = new ArrayList(); - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - Statement s = c.createStatement(); - ResultSet rs = s.executeQuery("SELECT * FROM product ORDER BY name"); - while (rs.next()) { - list.add(new Product(rs.getInt("product_id"), - rs.getString("name"), - rs.getString("description"), - rs.getString("image"), - rs.getString("category"), - rs.getDouble("price"), - rs.getInt("qty_in_stock"))); - } - } catch (SQLException e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - Product[] products = new Product[list.size()]; - Iterator i = list.iterator(); - int index = 0; - while(i.hasNext()) { - products[index] = (Product)i.next(); - index++; - } - return products; - } - - public List getProductsByName(String name) throws DAOException { - - List list = new ArrayList(); - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("SELECT * FROM product WHERE UPPER(name) LIKE ? ORDER BY name"); - ps.setString(1, "%" + name.toUpperCase() + "%"); - ResultSet rs = ps.executeQuery(); - while (rs.next()) { - list.add(new Product(rs.getInt("product_id"), - rs.getString("name"), - rs.getString("description"), - rs.getString("image"), - rs.getString("category"), - rs.getDouble("price"), - rs.getInt("qty_in_stock"))); - } - } catch (SQLException e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - return list; - - } - - public Product getProduct(int productId) throws DAOException { - - Product product = new Product(); - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("SELECT * FROM product WHERE product_id=?"); - ps.setInt(1, productId); - ResultSet rs = ps.executeQuery(); - if (rs.next()) { - product = new Product(); - product.setProductId(rs.getInt("product_id")); - product.setName(rs.getString("name")); - product.setDescription(rs.getString("description")); - product.setImage(rs.getString("image")); - product.setCategory(rs.getString("category")); - product.setPrice(rs.getDouble("price")); - product.setQtyInStock(rs.getInt("qty_in_stock")); - } - } catch (Exception e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - return product; - } - - public Product createProduct(Product product) throws DAOException { - - Connection c = null; - PreparedStatement ps = null; - try { - c = ConnectionHelper.getConnection(); - ps = c.prepareStatement("INSERT INTO product (name, description, image, category, price, qty_in_stock) VALUES (?, ?, ?, ?, ?, ?)"); - ps.setString(1, product.getName()); - ps.setString(2, product.getDescription()); - ps.setString(3, product.getImage()); - ps.setString(4, product.getCategory()); - ps.setDouble(5, product.getPrice()); - ps.setInt(6, product.getQtyInStock()); - ps.executeUpdate(); - Statement s = c.createStatement(); - // HSQLDB Syntax to get the identity (company_id) of inserted row - ResultSet rs = s.executeQuery("CALL IDENTITY()"); - // MySQL Syntax to get the identity (product_id) of inserted row - // ResultSet rs = s.executeQuery("SELECT LAST_INSERT_ID()"); - rs.next(); - // Update the id in the returned object. This is important as this value must get returned to the client. - product.setProductId(rs.getInt(1)); - } catch (Exception e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - return product; - } - - public void updateProduct(Product product) throws DAOException { - - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("UPDATE product SET name=?, description=?, image=?, category=?, price=?, qty_in_stock=? WHERE product_id=?"); - ps.setString(1, product.getName()); - ps.setString(2, product.getDescription()); - ps.setString(3, product.getImage()); - ps.setString(4, product.getCategory()); - ps.setDouble(5, product.getPrice()); - ps.setInt(6, product.getQtyInStock()); - ps.setInt(7, product.getProductId()); - ps.executeUpdate(); - } catch (SQLException e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - - } - - private boolean remove(Product product) throws DAOException { - - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("DELETE FROM product WHERE product_id=?"); - ps.setInt(1, product.getProductId()); - int count = ps.executeUpdate(); - return (count == 1); - } catch (Exception e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - } - - public boolean deleteProduct(Product product) throws DAOException { - return remove(product); - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/feed/Feed.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/feed/Feed.java b/apps/samples/WEB-INF/src/flex/samples/feed/Feed.java deleted file mode 100755 index 5f31a28..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/feed/Feed.java +++ /dev/null @@ -1,85 +0,0 @@ -/* - * 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 flex.samples.feed; - -import java.util.*; -import flex.messaging.MessageBroker; -import flex.messaging.messages.AsyncMessage; -import flex.messaging.util.UUIDUtils; - -public class Feed { - private static FeedThread thread; - - public Feed() { - } - - public void start() { - if (thread == null) { - thread = new FeedThread(); - thread.start(); - } - } - - public void stop() { - thread.running = false; - thread = null; - } - - public static class FeedThread extends Thread { - - public boolean running = true; - - public void run() { - MessageBroker msgBroker = MessageBroker.getMessageBroker(null); - String clientID = UUIDUtils.createUUID(); - - Random random = new Random(); - double initialValue = 35; - double currentValue = 35; - double maxChange = initialValue * 0.005; - - while (running) { - double change = maxChange - random.nextDouble() * maxChange * 2; - double newValue = currentValue + change; - - if (currentValue < initialValue + initialValue * 0.15 - && currentValue > initialValue - initialValue * 0.15) { - currentValue = newValue; - } else { - currentValue -= change; - } - - AsyncMessage msg = new AsyncMessage(); - msg.setDestination("feed"); - msg.setClientId(clientID); - msg.setMessageId(UUIDUtils.createUUID()); - msg.setTimestamp(System.currentTimeMillis()); - msg.setBody(new Double(currentValue)); - msgBroker.routeMessageToService(msg, null); - - System.out.println("" + currentValue); - - try { - Thread.sleep(300); - } catch (InterruptedException e) { - } - - } - } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/marketdata/Feed.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/marketdata/Feed.java b/apps/samples/WEB-INF/src/flex/samples/marketdata/Feed.java deleted file mode 100755 index 19e7247..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/marketdata/Feed.java +++ /dev/null @@ -1,121 +0,0 @@ -/* - * 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 flex.samples.marketdata; - -import java.util.*; - -import flex.messaging.MessageBroker; -import flex.messaging.messages.AsyncMessage; -import flex.messaging.util.UUIDUtils; - -public class Feed { - - public static void main(String args[]) { - Feed feed = new Feed(); - feed.start(); - } - - private static FeedThread thread; - - public Feed() { - } - - public void start() { - if (thread == null) { - thread = new FeedThread(); - thread.start(); - } - } - - public void stop() { - thread.running = false; - thread = null; - } - - public static class FeedThread extends Thread { - - public boolean running = true; - - private Random random; - - public void run() { - - MessageBroker msgBroker = MessageBroker.getMessageBroker(null); - String clientID = UUIDUtils.createUUID(); - - Portfolio portfolio = new Portfolio(); - List stocks = portfolio.getStocks(); - int size = stocks.size(); - int index = 0; - - random = new Random(); - - Stock stock; - - while (running) { - - stock = (Stock) stocks.get(index); - simulateChange(stock); - - index++; - if (index >= size) { - index = 0; - } - - AsyncMessage msg = new AsyncMessage(); - msg.setDestination("market-data-feed"); - msg.setHeader("DSSubtopic", stock.getSymbol()); - msg.setClientId(clientID); - msg.setMessageId(UUIDUtils.createUUID()); - msg.setTimestamp(System.currentTimeMillis()); - msg.setBody(stock); - msgBroker.routeMessageToService(msg, null); - - try { - Thread.sleep(20); - } catch (InterruptedException e) { - } - - } - } - - private void simulateChange(Stock stock) { - - double maxChange = stock.open * 0.005; - double change = maxChange - random.nextDouble() * maxChange * 2; - stock.change = change; - double last = stock.last + change; - - if (last < stock.open + stock.open * 0.15 - && last > stock.open - stock.open * 0.15) { - stock.last = last; - } else { - stock.last = stock.last - change; - } - - if (stock.last > stock.high) { - stock.high = stock.last; - } else if (stock.last < stock.low) { - stock.low = stock.last; - } - stock.date = new Date(); - - } - - } - -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/marketdata/Portfolio.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/marketdata/Portfolio.java b/apps/samples/WEB-INF/src/flex/samples/marketdata/Portfolio.java deleted file mode 100755 index 250dc10..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/marketdata/Portfolio.java +++ /dev/null @@ -1,75 +0,0 @@ -/* - * 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 flex.samples.marketdata; - -import java.io.*; -import java.net.URLDecoder; - -import javax.xml.parsers.*; -import org.w3c.dom.*; -import java.util.List; -import java.util.ArrayList; - -public class Portfolio { - - public static void main(String[] args) { - Portfolio stockFeed = new Portfolio(); - stockFeed.getStocks(); - } - - public List getStocks() { - - List list = new ArrayList(); - - try { - InputStream is = getClass().getClassLoader().getResourceAsStream("flex/samples/marketdata/portfolio.xml"); - DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); - factory.setValidating(false); - Document doc = factory.newDocumentBuilder().parse(is); - NodeList stockNodes = doc.getElementsByTagName("stock"); - int length = stockNodes.getLength(); - Stock stock; - Node stockNode; - for (int i=0; i<length; i++) { - stockNode = stockNodes.item(i); - stock = new Stock(); - stock.setSymbol( getStringValue(stockNode, "symbol") ); - stock.setName( getStringValue(stockNode, "company") ); - stock.setLast( getDoubleValue(stockNode, "last") ); - stock.setHigh( stock.getLast() ); - stock.setLow( stock.getLast() ); - stock.setOpen( stock.getLast() ); - stock.setChange( 0 ); - list.add(stock); - System.out.println(stock.getSymbol()); - } - } catch (Exception e) { - e.printStackTrace(); - } - - return list; - } - - private String getStringValue(Node node, String name) { - return ((Element) node).getElementsByTagName(name).item(0).getFirstChild().getNodeValue(); - } - - private double getDoubleValue(Node node, String name) { - return Double.parseDouble( getStringValue(node, name) ); - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/marketdata/Stock.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/marketdata/Stock.java b/apps/samples/WEB-INF/src/flex/samples/marketdata/Stock.java deleted file mode 100755 index 6e4b9ee..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/marketdata/Stock.java +++ /dev/null @@ -1,84 +0,0 @@ -/* - * 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 flex.samples.marketdata; - -import java.util.Date; -import java.io.Serializable; - -public class Stock implements Serializable { - - private static final long serialVersionUID = -8334804402463267285L; - - protected String symbol; - protected String name; - protected double low; - protected double high; - protected double open; - protected double last; - protected double change; - protected Date date; - - public double getChange() { - return change; - } - public void setChange(double change) { - this.change = change; - } - public double getHigh() { - return high; - } - public void setHigh(double high) { - this.high = high; - } - public double getLast() { - return last; - } - public void setLast(double last) { - this.last = last; - } - public double getLow() { - return low; - } - public void setLow(double low) { - this.low = low; - } - public String getName() { - return name; - } - public void setName(String name) { - this.name = name; - } - public double getOpen() { - return open; - } - public void setOpen(double open) { - this.open = open; - } - public String getSymbol() { - return symbol; - } - public void setSymbol(String symbol) { - this.symbol = symbol; - } - public Date getDate() { - return date; - } - public void setDate(Date date) { - this.date = date; - } - -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/marketdata/portfolio.xml ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/marketdata/portfolio.xml b/apps/samples/WEB-INF/src/flex/samples/marketdata/portfolio.xml deleted file mode 100755 index b464290..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/marketdata/portfolio.xml +++ /dev/null @@ -1,141 +0,0 @@ -<!-- - -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. - ---> -<portfolio> - - <stock> - <symbol>XOM</symbol> - <company>Exxon Mobile Corp</company> - <last>61.56</last> - </stock> - - <stock> - <symbol>WMT</symbol> - <company>Wal-Mart Stores</company> - <last>45.62</last> - </stock> - - <stock> - <symbol>GM</symbol> - <company>General Motors Corporation</company> - <last>19.8</last> - </stock> - - <stock> - <symbol>CVX</symbol> - <company>Chevron Corp New</company> - <last>58.95</last> - </stock> - - <stock> - <symbol>COP</symbol> - <company>Conocophillips</company> - <last>67.14</last> - </stock> - - <stock> - <symbol>GE</symbol> - <company>General Electric Company</company> - <last>33.61</last> - </stock> - - <stock> - <symbol>C</symbol> - <company>Citigroup Inc</company> - <last>48.18</last> - </stock> - - <stock> - <symbol>AIG</symbol> - <company>American International Group Inc</company> - <last>62.92</last> - </stock> - - <stock> - <symbol>GOOG</symbol> - <company>Google Inc</company> - <last>417.93</last> - </stock> - - <stock> - <symbol>ADBE</symbol> - <company>Adobe Systems Incorporated</company> - <last>39.20</last> - </stock> - - <stock> - <symbol>JBLU</symbol> - <company>JetBlue Airways Corporation</company> - <last>10.57</last> - </stock> - - <stock> - <symbol>COKE</symbol> - <company>Coca-Cola Bottling Co. Consolidated</company> - <last>48.20</last> - </stock> - - <stock> - <symbol>GENZ</symbol> - <company>Genzyme Corporation</company> - <last>61.16</last> - </stock> - - <stock> - <symbol>YHOO</symbol> - <company>Yahoo Inc.</company> - <last>32.78</last> - </stock> - - <stock> - <symbol>IBM</symbol> - <company>International Business Machines Corp.</company> - <last>82.34</last> - </stock> - - <stock> - <symbol>BA</symbol> - <company>Boeing Company</company> - <last>83.45</last> - </stock> - - <stock> - <symbol>SAP</symbol> - <company>SAP AG</company> - <last>54.63</last> - </stock> - - <stock> - <symbol>MOT</symbol> - <company>Motorola, Inc.</company> - <last>21.35</last> - </stock> - - <stock> - <symbol>VZ</symbol> - <company>Verizon Communications</company> - <last>33.03</last> - </stock> - - <stock> - <symbol>MCD</symbol> - <company>McDonald's Corporation</company> - <last>34.57</last> - </stock> - -</portfolio> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/product/Product.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/product/Product.java b/apps/samples/WEB-INF/src/flex/samples/product/Product.java deleted file mode 100755 index 7e3c87d..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/product/Product.java +++ /dev/null @@ -1,89 +0,0 @@ -/* - * 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 flex.samples.product; -import java.io.Serializable; - -public class Product implements Serializable { - - static final long serialVersionUID = 103844514947365244L; - - private int productId; - private String name; - private String description; - private String image; - private String category; - private double price; - private int qtyInStock; - - public Product() { - - } - - public Product(int productId, String name, String description, String image, String category, double price, int qtyInStock) { - this.productId = productId; - this.name = name; - this.description = description; - this.image = image; - this.category = category; - this.price = price; - this.qtyInStock = qtyInStock; - } - - public String getCategory() { - return category; - } - public void setCategory(String category) { - this.category = category; - } - public String getDescription() { - return description; - } - public void setDescription(String description) { - this.description = description; - } - public String getImage() { - return image; - } - public void setImage(String image) { - this.image = image; - } - public String getName() { - return name; - } - public void setName(String name) { - this.name = name; - } - public double getPrice() { - return price; - } - public void setPrice(double price) { - this.price = price; - } - public int getProductId() { - return productId; - } - public void setProductId(int productId) { - this.productId = productId; - } - public int getQtyInStock() { - return qtyInStock; - } - public void setQtyInStock(int qtyInStock) { - this.qtyInStock = qtyInStock; - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/product/ProductService.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/product/ProductService.java b/apps/samples/WEB-INF/src/flex/samples/product/ProductService.java deleted file mode 100755 index 8e0a816..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/product/ProductService.java +++ /dev/null @@ -1,191 +0,0 @@ -/* - * 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 flex.samples.product; - -import java.util.ArrayList; -import java.util.List; -import java.sql.*; - -import flex.samples.ConnectionHelper; -import flex.samples.DAOException; - -public class ProductService { - - public List getProducts() throws DAOException { - - List list = new ArrayList(); - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - Statement s = c.createStatement(); - ResultSet rs = s.executeQuery("SELECT * FROM product ORDER BY name"); - while (rs.next()) { - list.add(new Product(rs.getInt("product_id"), - rs.getString("name"), - rs.getString("description"), - rs.getString("image"), - rs.getString("category"), - rs.getDouble("price"), - rs.getInt("qty_in_stock"))); - } - } catch (SQLException e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - return list; - - } - - public List getProductsByName(String name) throws DAOException { - - List list = new ArrayList(); - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("SELECT * FROM product WHERE UPPER(name) LIKE ? ORDER BY name"); - ps.setString(1, "%" + name.toUpperCase() + "%"); - ResultSet rs = ps.executeQuery(); - while (rs.next()) { - list.add(new Product(rs.getInt("product_id"), - rs.getString("name"), - rs.getString("description"), - rs.getString("image"), - rs.getString("category"), - rs.getDouble("price"), - rs.getInt("qty_in_stock"))); - } - } catch (SQLException e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - return list; - - } - - public Product getProduct(int productId) throws DAOException { - - Product product = new Product(); - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("SELECT * FROM product WHERE product_id=?"); - ps.setInt(1, productId); - ResultSet rs = ps.executeQuery(); - if (rs.next()) { - product = new Product(); - product.setProductId(rs.getInt("product_id")); - product.setName(rs.getString("name")); - product.setDescription(rs.getString("description")); - product.setImage(rs.getString("image")); - product.setCategory(rs.getString("category")); - product.setPrice(rs.getDouble("price")); - product.setQtyInStock(rs.getInt("qty_in_stock")); - } - } catch (Exception e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - return product; - } - - public Product create(Product product) throws DAOException { - - Connection c = null; - PreparedStatement ps = null; - try { - c = ConnectionHelper.getConnection(); - ps = c.prepareStatement("INSERT INTO product (name, description, image, category, price, qty_in_stock) VALUES (?, ?, ?, ?, ?, ?)"); - ps.setString(1, product.getName()); - ps.setString(2, product.getDescription()); - ps.setString(3, product.getImage()); - ps.setString(4, product.getCategory()); - ps.setDouble(5, product.getPrice()); - ps.setInt(6, product.getQtyInStock()); - ps.executeUpdate(); - Statement s = c.createStatement(); - // HSQLDB Syntax to get the identity (company_id) of inserted row - ResultSet rs = s.executeQuery("CALL IDENTITY()"); - // MySQL Syntax to get the identity (product_id) of inserted row - // ResultSet rs = s.executeQuery("SELECT LAST_INSERT_ID()"); - rs.next(); - // Update the id in the returned object. This is important as this value must get returned to the client. - product.setProductId(rs.getInt(1)); - } catch (Exception e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - return product; - } - - public boolean update(Product product) throws DAOException { - - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("UPDATE product SET name=?, description=?, image=?, category=?, price=?, qty_in_stock=? WHERE product_id=?"); - ps.setString(1, product.getName()); - ps.setString(2, product.getDescription()); - ps.setString(3, product.getImage()); - ps.setString(4, product.getCategory()); - ps.setDouble(5, product.getPrice()); - ps.setInt(6, product.getQtyInStock()); - ps.setInt(7, product.getProductId()); - return (ps.executeUpdate() == 1); - } catch (SQLException e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - - } - - public boolean remove(Product product) throws DAOException { - - Connection c = null; - - try { - c = ConnectionHelper.getConnection(); - PreparedStatement ps = c.prepareStatement("DELETE FROM product WHERE product_id=?"); - ps.setInt(1, product.getProductId()); - int count = ps.executeUpdate(); - return (count == 1); - } catch (Exception e) { - e.printStackTrace(); - throw new DAOException(e); - } finally { - ConnectionHelper.close(c); - } - } - - public boolean delete(Product product) throws DAOException { - return remove(product); - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/qos/CustomDelayQueueProcessor.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/qos/CustomDelayQueueProcessor.java b/apps/samples/WEB-INF/src/flex/samples/qos/CustomDelayQueueProcessor.java deleted file mode 100755 index 3841e2a..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/qos/CustomDelayQueueProcessor.java +++ /dev/null @@ -1,121 +0,0 @@ -/* - * 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 flex.samples.qos; - -import java.util.ArrayList; -import java.util.List; - -import flex.messaging.client.FlexClient; -import flex.messaging.client.FlexClientOutboundQueueProcessor; -import flex.messaging.client.FlushResult; -import flex.messaging.config.ConfigMap; -import flex.messaging.MessageClient; - -/** - * Per client queue processor that applies custom quality of services parameters (in this case: delay). - * Custom quality of services parameters are read from the client FlexClient instance. - * In this sample, these parameters are set in the FlexClient instance by the client application - * using the flex.samples.qos.FlexClientConfigService RemoteObject. - * - * This class is used in the channel definition (see services-config.xml)that the 'market-data-feed' - * message destination (see messaging-config.xml) references. - * - * Each client that connects to this channel's endpoint gets a unique instance of this class to manage - * its specific outbound queue of messages. - */ -public class CustomDelayQueueProcessor extends FlexClientOutboundQueueProcessor -{ - /** - * Used to store the last time this queue was flushed. - * Starts off with an initial value of the construct time for the instance. - */ - private long lastFlushTime = System.currentTimeMillis(); - - /** - * Driven by configuration, this is the configurable delay time between flushes. - */ - private int delayTimeBetweenFlushes; - - public CustomDelayQueueProcessor() { - } - - /** - * Sets up the default delay time between flushes. This default is used if a client-specific - * value has not been set in the FlexClient instance. - * - * @param properties A ConfigMap containing any custom initialization properties. - */ - public void initialize(ConfigMap properties) - { - delayTimeBetweenFlushes = properties.getPropertyAsInt("flush-delay", -1); - if (delayTimeBetweenFlushes < 0) - throw new RuntimeException("Flush delay time for DelayedDeliveryQueueProcessor must be a positive value."); - } - - /** - * This flush implementation delays flushing messages from the queue until 3 seconds - * have passed since the last flush. - * - * @param outboundQueue The queue of outbound messages. - * @return An object containing the messages that have been removed from the outbound queue - * to be written to the network and a wait time for the next flush of the outbound queue - * that is the default for the underlying Channel/Endpoint. - */ - public FlushResult flush(List outboundQueue) - { - int delay = delayTimeBetweenFlushes; - // Read custom delay from client's FlexClient instance - FlexClient flexClient = getFlexClient(); - if (flexClient != null) - { - Object obj = flexClient.getAttribute("market-data-delay"); - if (obj != null) - { - try { - delay = Integer.parseInt((String) obj); - } catch (NumberFormatException ignore) { - } - } - } - - long currentTime = System.currentTimeMillis(); - if ((currentTime - lastFlushTime) < delay) - { - // Delaying flush. No messages will be returned at this point - FlushResult flushResult = new FlushResult(); - // Don't return any messages to flush. - // And request that the next flush doesn't occur until 3 seconds since the previous. - flushResult.setNextFlushWaitTimeMillis((int)(delay - (currentTime - lastFlushTime))); - return flushResult; - } - else // OK to flush. - { - // Flushing. All queued messages will now be returned - lastFlushTime = currentTime; - FlushResult flushResult = new FlushResult(); - flushResult.setNextFlushWaitTimeMillis(delay); - flushResult.setMessages(new ArrayList(outboundQueue)); - outboundQueue.clear(); - return flushResult; - } - } - - public FlushResult flush(MessageClient client, List outboundQueue) { - return super.flush(client, outboundQueue); - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/qos/FlexClientConfigService.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/qos/FlexClientConfigService.java b/apps/samples/WEB-INF/src/flex/samples/qos/FlexClientConfigService.java deleted file mode 100755 index c66d46b..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/qos/FlexClientConfigService.java +++ /dev/null @@ -1,74 +0,0 @@ -/* - * 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 flex.samples.qos; - -import java.util.ArrayList; -import java.util.Enumeration; -import java.util.List; - -import flex.messaging.FlexContext; -import flex.messaging.client.FlexClient; - -public class FlexClientConfigService -{ - - public void setAttribute(String name, Object value) - { - FlexClient flexClient = FlexContext.getFlexClient(); - flexClient.setAttribute(name, value); - } - - public List getAttributes() - { - FlexClient flexClient = FlexContext.getFlexClient(); - List attributes = new ArrayList(); - Enumeration attrNames = flexClient.getAttributeNames(); - while (attrNames.hasMoreElements()) - { - String attrName = (String) attrNames.nextElement(); - attributes.add(new Attribute(attrName, flexClient.getAttribute(attrName))); - } - - return attributes; - - } - - public class Attribute { - - private String name; - private Object value; - - public Attribute(String name, Object value) { - this.name = name; - this.value = value; - } - public String getName() { - return name; - } - public void setName(String name) { - this.name = name; - } - public Object getValue() { - return value; - } - public void setValue(Object value) { - this.value = value; - } - - } - -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/ChatRoomService.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/ChatRoomService.java b/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/ChatRoomService.java deleted file mode 100755 index 9e83da5..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/ChatRoomService.java +++ /dev/null @@ -1,81 +0,0 @@ -/* - * 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 flex.samples.runtimeconfig; - -import java.util.ArrayList; -import java.util.Collections; -import java.util.List; -import flex.messaging.MessageBroker; -import flex.messaging.MessageDestination; -//import flex.messaging.config.ServerSettings; -import flex.messaging.services.MessageService; - -/** - * Simplistic implementation of a chat room management service. Clients can add rooms, - * and obtain a list of rooms. The interesting part of this example is the "on-the-fly" - * creation of a message destination. The same technique can be used to create DataService - * and Remoting destinations. - */ -public class ChatRoomService { - - private List rooms; - - public ChatRoomService() - { - rooms = Collections.synchronizedList(new ArrayList()); - } - - public List getRoomList() - { - return rooms; - } - - public void createRoom(String id) { - - if (roomExists(id)) - { - throw new RuntimeException("Room already exists"); - } - - // Create a new Message destination dynamically - String serviceId = "message-service"; - MessageBroker broker = MessageBroker.getMessageBroker(null); - MessageService service = (MessageService) broker.getService(serviceId); - MessageDestination destination = (MessageDestination) service.createDestination(id); - - if (service.isStarted()) - { - destination.start(); - } - - rooms.add(id); - - } - - public boolean roomExists(String id) - { - int size = rooms.size(); - for (int i=0; i<size; i++) - { - if ( ((String)rooms.get(i)).equals(id) ) - { - return true; - } - } - return false; - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/EmployeeRuntimeRemotingDestination.java ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/EmployeeRuntimeRemotingDestination.java b/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/EmployeeRuntimeRemotingDestination.java deleted file mode 100755 index 4624eba..0000000 --- a/apps/samples/WEB-INF/src/flex/samples/runtimeconfig/EmployeeRuntimeRemotingDestination.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * 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 flex.samples.runtimeconfig; - -import flex.messaging.config.ConfigMap; -import flex.messaging.services.AbstractBootstrapService; -import flex.messaging.services.RemotingService; -import flex.messaging.services.remoting.RemotingDestination; - -public class EmployeeRuntimeRemotingDestination extends AbstractBootstrapService -{ - private RemotingService remotingService; - - /** - * This method is called by FDS when FDS has been initialized but not started. - */ - public void initialize(String id, ConfigMap properties) - { - remotingService = (RemotingService) getMessageBroker().getService("remoting-service"); - RemotingDestination destination = (RemotingDestination) remotingService.createDestination(id); - destination.setSource("flex.samples.crm.employee.EmployeeDAO"); - } - - /** - * This method is called by FDS as FDS starts up (after initialization). - */ - public void start() - { - // No-op - } - - /** - * This method is called by FDS as FDS shuts down. - */ - public void stop() - { - // No-op - } - -} http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/WEB-INF/web.xml ---------------------------------------------------------------------- diff --git a/apps/samples/WEB-INF/web.xml b/apps/samples/WEB-INF/web.xml deleted file mode 100755 index 0a97d59..0000000 --- a/apps/samples/WEB-INF/web.xml +++ /dev/null @@ -1,63 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - - 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. - ---> - -<!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd";> - -<web-app> - <display-name>BlazeDS Samples</display-name> - <description>BlazeDS Sample Application</description> - - <!-- Http Flex Session attribute and binding listener support --> - <listener> - <listener-class>flex.messaging.HttpFlexSession</listener-class> - </listener> - - <!-- MessageBroker Servlet --> - <servlet> - <servlet-name>MessageBrokerServlet</servlet-name> - <display-name>MessageBrokerServlet</display-name> - <servlet-class>flex.messaging.MessageBrokerServlet</servlet-class> - <init-param> - <param-name>services.configuration.file</param-name> - <param-value>/WEB-INF/flex/services-config.xml</param-value> - </init-param> - <load-on-startup>1</load-on-startup> - </servlet> - <servlet-mapping> - <servlet-name>MessageBrokerServlet</servlet-name> - <url-pattern>/messagebroker/*</url-pattern> - </servlet-mapping> - - <welcome-file-list> - <welcome-file>index.htm</welcome-file> - </welcome-file-list> - - <!-- for WebSphere deployment, please uncomment --> - <!-- - <resource-ref> - <description>Flex Messaging WorkManager</description> - <res-ref-name>wm/MessagingWorkManager</res-ref-name> - <res-type>com.ibm.websphere.asynchbeans.WorkManager</res-type> - <res-auth>Container</res-auth> - <res-sharing-scope>Shareable</res-sharing-scope> - </resource-ref> - --> - -</web-app> http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/build.xml ---------------------------------------------------------------------- diff --git a/apps/samples/build.xml b/apps/samples/build.xml deleted file mode 100755 index 609d314..0000000 --- a/apps/samples/build.xml +++ /dev/null @@ -1,168 +0,0 @@ -<?xml version="1.0"?> -<!-- - - 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. - ---> - - -<project name="samples.war/build.xml" default="main" basedir="../.."> - <property file="${basedir}/build.properties"/> - <property name="samples.war" value="${basedir}/apps/samples"/> - <property name="dist.dir" value="${basedir}/dist"/> - <property name="src.dir" value="${samples.war}/WEB-INF/src"/> - <property name="classes.dir" value="${samples.war}/WEB-INF/classes"/> - <property name="context.root" value="samples" /> - - <path id="classpath"> - <fileset dir="${samples.war}/WEB-INF/lib" includes="**/*.jar"/> - <pathelement location="${servlet.jar}"/> - <pathelement location="${jms.jar}"/> - </path> - - <target name="main" depends="clean,samples"/> - <target name="samples" depends="prepare,copy-resources,compile"/> - - <target name="prepare"> - <mkdir dir="${samples.war}/WEB-INF/lib"/> - <mkdir dir="${samples.war}/WEB-INF/classes"/> - </target> - - <target name="copy-resources"> - <fail unless="local.sdk.lib.dir" message="must specify local.sdk.lib.dir in server/build.properties"/> - <fail unless="local.sdk.frameworks.dir" message="must specify local.sdk.frameworks.dir in build.properties"/> - - <!-- copy to the lib directory --> - <copy todir="${samples.war}/WEB-INF/lib"> - <fileset dir="${basedir}/lib" includes="${webapp.lib}" /> - <fileset file="${hsqldb.jar}" /> - </copy> - - <!-- copy to sampledb directory --> - <copy todir="${basedir}/sampledb"> - <fileset file="${hsqldb.jar}" /> - </copy> - - <!-- copy to the classes directory --> - <copy todir="${samples.war}/WEB-INF/classes"> - <fileset dir="${samples.war}/WEB-INF/src"> - <include name="**/*.xml"/> - </fileset> - <fileset dir="${basedir}/lib" includes="${webapp.classes}"/> - </copy> - - <!-- create version.properties --> - <propertyfile file="${samples.war}/WEB-INF/flex/version.properties"> - <entry key="build" value="${manifest.Implementation-Version}.${build.number}"/> - <entry key="minimumSDKVersion" value="${min.sdk.version}"/> - </propertyfile> - - </target> - - <target name="run-depend" if="src.depend"> - <echo message="Removing class files that changed and dependent class files."/> - <depend cache="${classes.dir}" srcdir="${src.dir}" destdir="${classes.dir}"/> - </target> - - <target name="compile" depends="prepare,run-depend,copy-resources" description="compile"> - <javac source="1.4" debug="${src.debug}" destdir="${classes.dir}" srcdir="${src.dir}" classpathref="classpath"/> - </target> - - <target name="compile-swfs"> - <property name="samples.src.dir" value="${samples.war}/WEB-INF/flex-src" /> - - <ant antfile="${samples.src.dir}/dashboard/build.xml" /> - <ant antfile="${samples.src.dir}/runtimeconfig-messaging/build.xml" /> - <ant antfile="${samples.src.dir}/runtimeconfig-remoting/build.xml" /> - <ant antfile="${samples.src.dir}/testdrive-101/build.xml" /> - <ant antfile="${samples.src.dir}/testdrive-chat/build.xml" /> - <ant antfile="${samples.src.dir}/testdrive-datapush/build.xml" /> - <ant antfile="${samples.src.dir}/testdrive-httpservice/build.xml" /> - <ant antfile="${samples.src.dir}/testdrive-remoteobject/build.xml" /> - <ant antfile="${samples.src.dir}/testdrive-update/build.xml" /> - <ant antfile="${samples.src.dir}/testdrive-webservice/build.xml" /> - <ant antfile="${samples.src.dir}/traderdesktop/build.xml" /> - <ant antfile="${samples.src.dir}/inventory/build.xml" /> - - </target> - - <target name="package" depends="compile-swfs" description=" Creates distribution war file"> - - <mkdir dir="${dist.dir}"/> - - <!-- - we don't want flex source naked in WEB-INF as that would lead to overlapping eclipse projects - instead, zip it up and then put it in the war - --> - <zip destfile="${samples.war}/WEB-INF/flex-src/flex-src.zip" - comment="${manifest.Implementation-Title} ${manifest.Implementation-Version}.${label} Samples Flex Source Code"> - <fileset dir="${samples.war}/WEB-INF/flex-src" - excludes="**/build*.xml,flex-src.zip"/> - </zip> - - <war file="${dist.dir}/samples.war" - webxml="${samples.war}/WEB-INF/web.xml"> - <manifest> - <attribute name="Sealed" value="${manifest.sealed}"/> - <attribute name="Implementation-Title" value="${manifest.Implementation-Title} - Samples Application"/> - <attribute name="Implementation-Version" value="${manifest.Implementation-Version}.${build.number}"/> - <attribute name="Implementation-Vendor" value="${manifest.Implementation-Vendor}"/> - </manifest> - <fileset dir="${samples.war}" > - <exclude name="**/**/build*.xml" /> - <exclude name="**/generated/**/*"/> - <exclude name="WEB-INF/jsp/**/*" /> - <exclude name="WEB-INF/sessions/**/*" /> - <exclude name="WEB-INF/flex-src/**/*" /> - <!-- This is included in the war task already --> - <exclude name="WEB-INF/web.xml" /> - </fileset> - <fileset dir="${samples.war}" includes="WEB-INF/flex-src/flex-src.zip" /> - </war> - - <copy todir="${dist.dir}/sampledb"> - <fileset dir="${basedir}/sampledb" /> - <fileset file="${hsqldb.jar}" /> - </copy> - - </target> - - <target name="clean" description="--> Removes jars and classes"> - <delete quiet="true" includeEmptyDirs="true"> - <fileset dir="${samples.war}/WEB-INF/lib" includes="${webapp.lib},${webtier.lib},${hsqldb.jar}"/> - <fileset dir="${samples.war}/WEB-INF/flex/jars" includes="**/*"/> - <fileset dir="${samples.war}/WEB-INF/flex/locale" includes="**/*"/> - <fileset dir="${samples.war}/WEB-INF/flex/libs" includes="**/*"/> - <fileset dir="${samples.war}/WEB-INF/flex" includes="version.properties"/> - <fileset dir="${classes.dir}" includes="**/*.class"/> - <fileset dir="${basedir}/sampledb" includes="${hsqldb.jar}"/> - <fileset file="${dist.dir}/samples.war"/> - <fileset file="${samples.war}/WEB-INF/flex-src/flex-src.zip"/> - <fileset dir="${samples.war}/sqladmin"/> - <fileset dir="${classes.dir}"/> - </delete> - </target> - - <target name="generated-clean"> - <delete includeEmptyDirs="true" quiet="true"> - <fileset dir="${samples.war}" includes="**/generated/*" /> - </delete> - <delete includeEmptyDirs="true" quiet="true"> - <fileset dir="${samples.war}" includes="**/generated" /> - </delete> - </target> - -</project> http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/fb-project-setup.htm ---------------------------------------------------------------------- diff --git a/apps/samples/fb-project-setup.htm b/apps/samples/fb-project-setup.htm deleted file mode 100755 index ddc387c..0000000 --- a/apps/samples/fb-project-setup.htm +++ /dev/null @@ -1,67 +0,0 @@ -<!-- - 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. ---> -<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";> -<html xmlns="http://www.w3.org/1999/xhtml";> -<head> -<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1" /> -<title>BlazeDS Flex Builder Integration</title> -<link href="main.css" rel="stylesheet" type="text/css" /> -</head> -<body> - -<h1>Opening the Samples Source Code in Flex Builder 3</h1> -<h3>Unziping the samples source code </h3> -<ol> - <li>Locate <strong>flex-src.zip</strong> in the <strong>WEB-INF\flex-src</strong> directory of the samples web application. For example, on a typical Windows installation using the Tomcat integrated server, flex-src.zip is located in C:\blazeds\tomcat\webapps\samples\WEB-INF\flex-src.</li> - <li>Unzip flex-src.zip to the root folder of your Flex Builder workspace.</li> -</ol> -<h3>Creating Flex Builder projects </h3> -<p>Create a Flex Builder project for each sample application you are interested in. There are several approaches to create a Flex Builder project for a Flex application that works with BlazeDS. We describe a simple approach here:</p> -<ol> - <li>Select <strong>File>New>Project…</strong> in the Flex Builder menu.</li> - <li> Expand Flex Builder, select <strong>Flex Project</strong> and click Next.</li> - <li> Provide a project name. Use the exact name of the sample folder. For example testdrive-httpservice.</li> - <li> If you unzipped flex-src.zip in the root folder of your Flex Builder workspace, keep the <strong>use default location</strong> checkbox checked.</li> - <li> Select <strong>Web Application</strong> as the application type.</li> - <li> Select <strong>Java</strong> as the application server type.</li> - <li> Check use <strong>remote object access service</strong>.</li> - <li> Uncheck Create combined Java/Flex project using WTP. <strong>Note</strong> this checkbox will only exist if the Eclipse WTP feature is installed.</li> - <li> Click <strong>Next</strong>.</li> - <li> Make sure the root folder for LiveCycle Data Services matches the root folder of your BlazeDS web application. If you are using the Tomcat integrated server on Windows, the settings should look similar to this (you may need to adjust the exact folder based on your own settings):</li> - <blockquote> - <p>Root Folder: C:\blazeds\tomcat\webapps\samples<br /> - Root URL: <a href="http://localhost:8400/lcds-samples/";>http://localhost:8400/samples/</a><br /> - Context Root: /samples</p> - </blockquote> - <li>Click <strong>Validate Configuration</strong>, then <strong>Finish</strong>.</li> -</ol> -<h3>Adding a linked resource to the server configuration files</h3> -<p>While working on the client-side of your applications, you may need to look at or change the BlazeDS server-side configuration. For example, you may need to look at existing destinations or create a new one. You can create a linked resource inside a Flex Builder project to make the BlazeDS configuration files easily accessible.</p> -<p>To create a linked resource to the BlazeDS configuration files: </p> -<ol> - <li>Right-click the project name in the project navigation view. </li> - <li>Select <strong>New>Folder</strong> in the popup menu.</li> - <li>Specify the name of the folder as it will appear in the navigation view. This name can be different from the name of the folder in the file system. For example type <strong>server-config</strong>. </li> - <li>Click the <strong>Advanced</strong> button.</li> - <li>Check <strong>Link to folder in the file system</strong>.</li> - <li>Click the <strong>Browse</strong> button and select the <strong>flex</strong> folder under the <strong>WEB-INF</strong> directory of your web application. For example, on a typical Windows installation using the Tomcat integrated server, select C:\blazeds\tomcat\webapps\samples\WEB-INF\flex. </li> - <li>Click <strong>Finish</strong>. The BlazeDS configuration files are now available in your Flex Builder project under the server-config folder. </li> -</ol> - -<p> </p> -</body> -</html> http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/images/blazeds.png ---------------------------------------------------------------------- diff --git a/apps/samples/images/blazeds.png b/apps/samples/images/blazeds.png deleted file mode 100755 index 669d4c9..0000000 Binary files a/apps/samples/images/blazeds.png and /dev/null differ http://git-wip-us.apache.org/repos/asf/flex-blazeds/blob/bf2e1dc9/apps/samples/index.htm ---------------------------------------------------------------------- diff --git a/apps/samples/index.htm b/apps/samples/index.htm deleted file mode 100755 index e12ec93..0000000 --- a/apps/samples/index.htm +++ /dev/null @@ -1,101 +0,0 @@ -<!-- - 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. ---> -<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";> -<html xmlns="http://www.w3.org/1999/xhtml";> -<head> -<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1" /> -<title>BlazeDS Samples</title> -<link href="main.css" rel="stylesheet" type="text/css" /> -</head> -<body> - -<h1><img src="images/blazeds.png" width="100" height="105" /></h1> -<h1>BlazeDS Samples </h1> -<div class="highlight"> -<h3>Starting the Samples Database </h3> -<p>You have to <strong>start the sample database</strong> before you can run the BlazeDS samples. The samples use an HSQLDB database that located in the [installdir]/sampledb directory.</p> -<p>To start the sample database:</p> -<ol> - <li>Open a command prompt and go to the [installdir]/sampledb</li> - <li>Run startdb.bat (Windows) or startdb.sh (Unix-based systems)</li> -</ol> -</div> -<h2>Source Code</h2> -<p>The source code for all the sample applications is available in samples\WEB-INF\flex-src\flex-src.zip. </p> -<ul> - <li>If you want to examine the source code using your favorite code editor, unzip <strong>flex-src.zip</strong> anywhere on your file system. </li> - <li>If you want to work with and compile the sample applications in <strong>Flash Builder</strong>, read <a href="fb-project-setup.htm">these instructions</a> to set up your Flash Builder projects. </li> -</ul> - -<h2>30 Minute Test Drive</h2> -<p>The objective of this test drive is to give you, in a very short amount of time, an understanding of how the BlazeDS data services work and what they can do. -This test drive consists of a series of eight samples kept as concise as possible (typically between 10 and 50 lines of code) to clearly expose features of interest. </p> - -<p><a href="testdrive.htm">Take the test drive</a></p> - -<h2>Other Samples</h2> -<ul> -<li><a href="#inventory">Inventory Management</a></li> -<li><a href="#traderdesktop">Trader Desktop</a></li> -<li><a href="#dashboard">Collaboration Dashboard</a></li> -<li><a href="#runtimeconfig">Runtime Configuration</a></li> -</ul> - -<div class="item"> -<a name="inventory"></a> -<h3>Inventory Management</h3> -<p>This application demonstrates how to use the RemoteObject to build a simple CRUD (Create/Update/Delete) application.</p> -<p>Click <a href="inventory/index.html">here</a> to start the Inventory Management application</p> -</div> - -<div class="item"> -<a name="traderdesktop"></a> -<h3>Trader Desktop </h3> -<p>This example demonstrates how to use the message service to push data from the server to the client. At the server side, a Java component publishes simulated market data to a BlazeDS messaging destination. The Trader Desktop application subscribes to real time updates for the stocks specified in a configurable watch list. This application lets you experiment with different types of channels (streaming, polling) supported by BlazeDS as well as a channel that uses adaptive polling. Using adaptive polling (using a per client outbound message queue processor), you have full control over how messages are handled by queue processors and delivered to individual clients. For example you can specify per-client delays for message delivery, and provide custom logic defining how messages are merged between deliveries.</p> -<ol> - <li>Click <a href="traderdesktop/startfeed.jsp">here</a> to start the feed</li> - <li>Click <a href="traderdesktop/index.html">here</a> to start the Trader Desktop application</li> - <li>Click <a href="traderdesktop/stopfeed.jsp">here</a> to stop the feed</li> -</ol> -</div> - - -<div class="item"> -<a name="dashboard"></a> -<h3>Collaboration Dashboard</h3> -<p>The Collaboration Dashboard show how you can use the Message Service to build collaborative applications. To try this sample, open the application in two different browser windows -and notice how selections made in one window are reflected in the other window. For example, the chart on the left shows total revenue across all regions on a monthly basis. -When you select a month in this chart, the pie chart in the upper right panel is updated to display a regional breakdown for the selected month. -If you select a region in the pie chart, the chart in the lower-right panel is updated to display the selected region's results compared to the average for the given time period.</p> -<p><a href="dashboard/index.html">Run the sample </a></p> -</div> - -<div class="item"> -<a name="runtimeconfig"></a> -<h3>Runtime Configuration </h3> -<p>Runtime configuration provides an alternative approach to defining destinations and adapters. In addition to statically defining destinations and adapters in the XML configuration files (remoting-config.xml and messaging-config.xml), you can create destinations and adapters programmatically at runtime. Your runtime destinations and adapters can be injected at server startup, or created as needed during the life cycle of an application. The remoting destination samples provide examples of destinations injected at server startup. The messaging sample provides an example of a destination created as needed. </p> -<h4>Remoting destination </h4> -<p><a href="runtimeconfig-remoting/index.html">Run the sample</a> </p> -<p>See flex.samples.runtimeconfig.EmployeeRuntimeRemotingDestination.java to see how the "runtime-employee-ro" destination is created programmatically.</p> -<h4>Messaging destination </h4> -<p><a href="runtimeconfig-messaging/index.html">Run the sample</a> </p> -<p>See flex.samples.runtimeconfig.ChatRoomService.java to see how the chat room destinations are created programmatically.</p> -</div> - -<p>© 2004-2010 Adobe Systems Incorporated. All rights reserved. </p> -</body> -</html> \ No newline at end of file
