ejava.examples.asyncmarket.ejb

Class AuctionMgmtEJB

java.lang.Object

ejava.examples.asyncmarket.ejb.AuctionMgmtEJB

All Implemented Interfaces:

AuctionMgmt, AuctionMgmtLocal, AuctionMgmtRemote

public class AuctionMgmtEJB
extends Object
implements AuctionMgmtRemote, AuctionMgmtLocal

Field Summary

Fields

Modifier and Type	Field and Description
private AuctionMgmtActionEJB	actions
private AuctionItemDAO	auctionItemDAO
(package private) long	checkItemInterval
private ConnectionFactory	connFactory
private EntityManager	em
private static org.apache.commons.logging.Log	log
private Destination	sellTopic
private TimerService	timerService
private PersonDAO	userDAO

Constructor Summary

Constructors

Constructor and Description
AuctionMgmtEJB()

Method Summary

Modifier and Type	Method and Description
void	cancelTimers()
int	checkAuction()
void	closeBidding(long itemId)
void	execute(Timer timer)
List<AuctionItem>	getItems(int index, int count)
Bid	getWinningBid(long itemId)
void	init()
void	initTimers(long delay)
void	initTimers(ScheduleExpression schedule)
private AuctionItem	makeDTO(AuctionItem item)
private AuctionItem	makeDTO(AuctionItem item, Bid bid)
private Bid	makeDTO(Bid bid)
private List<AuctionItem>	makeDTO(List<AuctionItem> items)
private List<Bid>	makeDTO(List<Bid> bids, AuctionItem item)
private Person	makeDTO(Person person, Bid bid)
protected void	publishAvailableItem(Session session, AuctionItem item)
void	removeBid(long bidId)
void	removeItem(long id)
void	workAsync(int count, long delay) Perform action async from caller.
void	workSync(int count, long delay) Perform action synchronously while caller waits.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static final org.apache.commons.logging.Log log

em

private EntityManager em

actions

private AuctionMgmtActionEJB actions

auctionItemDAO

private AuctionItemDAO auctionItemDAO

userDAO

private PersonDAO userDAO

timerService

private TimerService timerService

checkItemInterval

long checkItemInterval

connFactory

private ConnectionFactory connFactory

sellTopic

private Destination sellTopic

Constructor Detail

AuctionMgmtEJB

public AuctionMgmtEJB()

Method Detail

init

@PostConstruct
public void init()

cancelTimers

public void cancelTimers()

Specified by:

cancelTimers in interface AuctionMgmt

initTimers

public void initTimers(long delay)

Specified by:

initTimers in interface AuctionMgmt

initTimers

public void initTimers(ScheduleExpression schedule)

Specified by:

initTimers in interface AuctionMgmt

closeBidding

public void closeBidding(long itemId)
                  throws MarketException

Specified by:

closeBidding in interface AuctionMgmt

Throws:

MarketException

getWinningBid

public Bid getWinningBid(long itemId)
                  throws MarketException

Specified by:

getWinningBid in interface AuctionMgmt

Throws:

MarketException

makeDTO

private Bid makeDTO(Bid bid)

makeDTO

private Person makeDTO(Person person,
                       Bid bid)

makeDTO

private AuctionItem makeDTO(AuctionItem item,
                            Bid bid)

execute

public void execute(Timer timer)

checkAuction

public int checkAuction()
                 throws MarketException

Specified by:

checkAuction in interface AuctionMgmt

Throws:

MarketException

publishAvailableItem

protected void publishAvailableItem(Session session,
                                    AuctionItem item)
                             throws JMSException

Throws:

JMSException

removeBid

public void removeBid(long bidId)
               throws MarketException

Specified by:

removeBid in interface AuctionMgmt

Throws:

MarketException

getItems

public List<AuctionItem> getItems(int index,
                                  int count)
                           throws MarketException

Specified by:

getItems in interface AuctionMgmt

Throws:

MarketException

removeItem

public void removeItem(long id)
                throws MarketException

Specified by:

removeItem in interface AuctionMgmt

Throws:

MarketException

makeDTO

private List<AuctionItem> makeDTO(List<AuctionItem> items)

makeDTO

private AuctionItem makeDTO(AuctionItem item)

makeDTO

private List<Bid> makeDTO(List<Bid> bids,
                          AuctionItem item)

workSync

public void workSync(int count,
                     long delay)

Perform action synchronously while caller waits.

Specified by:

workSync in interface AuctionMgmtRemote

Parameters:

count - number of tasks to perform

workAsync

public void workAsync(int count,
                      long delay)

Perform action async from caller.

Specified by:

workAsync in interface AuctionMgmtRemote

Parameters:

count - number of tasks to perform